10/27/2025 02:03:44.849 7ff11032de00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 201
10/27/2025 02:03:44.851 7ff11032de00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)}
10/27/2025 02:03:44.851 7ff11032de00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff10f77d310> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)])
10/27/2025 02:03:44.851 7ff11032de00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/27/2025 02:03:44.851 7ff11032de00 [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=356595921, session_epoch=1033, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:44.851 7ff11032de00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 1039 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=356595921, session_epoch=1033, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:44.852 7ff11032de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296988.824463, idle connection 411992.000000, request 304999.919891
10/27/2025 02:03:44.852 7ff1106de2c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 49
10/27/2025 02:03:44.852 7ff1106de2c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)}
10/27/2025 02:03:44.852 7ff1106de2c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff10f77d070> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)])
10/27/2025 02:03:44.852 7ff1106de2c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/27/2025 02:03:44.852 7ff1106de2c0 [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=2054903511, session_epoch=1005, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:44.852 7ff1106de2c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 1010 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2054903511, session_epoch=1005, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:44.852 7ff1106de2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6095.118408, idle connection 411651.000000, request 304999.953985
10/27/2025 02:03:44.853 7ff11032dea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 282
10/27/2025 02:03:44.853 7ff11032dea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)}
10/27/2025 02:03:44.853 7ff11032dea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff10f77d490> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)])
10/27/2025 02:03:44.853 7ff11032dea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/27/2025 02:03:44.853 7ff11032dea0 [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=1108008487, session_epoch=1062, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:44.853 7ff11032dea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 1068 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1108008487, session_epoch=1062, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:44.853 7ff11032dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296992.184570, idle connection 412307.000000, request 304999.943256
10/27/2025 02:03:44.854 7ff11032de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296986.580811, idle connection 411990.000000, request 304997.687817
10/27/2025 02:03:44.854 7ff1106de2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6093.200928, idle connection 411649.000000, request 304998.038769
10/27/2025 02:03:44.855 7ff11032dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296990.604004, idle connection 412305.000000, request 304998.368263
10/27/2025 02:03:44.857 7ff1106eb7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6535.665527, idle connection 410991.000000, request 304399.069309
10/27/2025 02:03:44.858 7ff1106eb7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1004
10/27/2025 02:03:44.858 7ff1106eb7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:44.858 7ff1106eb7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 1004 (601.4182567596436 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1223561683, topics=[])
10/27/2025 02:03:44.858 7ff1106eb7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1223561683 with 0 response partitions (1 implied)
10/27/2025 02:03:44.860 7ff11032df40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 281
10/27/2025 02:03:44.860 7ff11032df40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)}
10/27/2025 02:03:44.860 7ff11032df40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff10f840e20> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)])
10/27/2025 02:03:44.860 7ff11032df40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/27/2025 02:03:44.860 7ff11032df40 [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=2460895, session_epoch=1060, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:44.860 7ff11032df40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 1066 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2460895, session_epoch=1060, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:44.861 7ff11032df40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296986.385986, idle connection 410968.000000, request 304999.956608
10/27/2025 02:03:44.861 7ff10f8d6cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4230.530273, idle connection 409912.000000, request 304397.056103
10/27/2025 02:03:44.861 7ff110767540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4990.857910, idle connection 410241.000000, request 304397.571087
10/27/2025 02:03:44.861 7ff11032df40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296985.617676, idle connection 410967.000000, request 304999.190807
10/27/2025 02:03:44.862 7ff10f8d6cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1003
10/27/2025 02:03:44.862 7ff10f8d6cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:44.862 7ff10f8d6cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 1003 (604.0139198303223 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1049378430, topics=[])
10/27/2025 02:03:44.862 7ff10f8d6cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1049378430 with 0 response partitions (1 implied)
10/27/2025 02:03:44.862 7ff110767540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1001
10/27/2025 02:03:44.862 7ff110767540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:44.862 7ff110767540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 1001 (603.8579940795898 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1731228986, topics=[])
10/27/2025 02:03:44.863 7ff110767540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1731228986 with 0 response partitions (1 implied)
10/27/2025 02:03:44.867 7ff1106a7ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 34
10/27/2025 02:03:44.867 7ff1106a7ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)}
10/27/2025 02:03:44.867 7ff1106a7ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff10f7d0040> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)])
10/27/2025 02:03:44.868 7ff1106a7ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/27/2025 02:03:44.868 7ff1106a7ea0 [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=702775847, session_epoch=996, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:44.868 7ff1106a7ea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 1001 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=702775847, session_epoch=996, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:44.868 7ff1106a7ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6949.075928, idle connection 410609.000000, request 304999.928236
10/27/2025 02:03:44.869 7ff1106a7ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6948.456299, idle connection 410608.000000, request 304999.315023
10/27/2025 02:03:45.038 7ff11032dc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 197
10/27/2025 02:03:45.038 7ff11032dc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)}
10/27/2025 02:03:45.038 7ff11032dc20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff10f77d850> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)])
10/27/2025 02:03:45.038 7ff11032dc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/27/2025 02:03:45.039 7ff11032dc20 [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=29594918, session_epoch=1055, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.039 7ff11032dc20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 1061 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=29594918, session_epoch=1055, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.039 7ff11032dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296929.567383, idle connection 410108.000000, request 304999.945879
10/27/2025 02:03:45.039 7ff10f8d6c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 2
10/27/2025 02:03:45.039 7ff10f8d6c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)}
10/27/2025 02:03:45.039 7ff10f8d6c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff10f778a00> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)])
10/27/2025 02:03:45.039 7ff10f8d6c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/27/2025 02:03:45.039 7ff10f8d6c20 [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=1840096657, session_epoch=991, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.039 7ff10f8d6c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 996 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1840096657, session_epoch=991, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.040 7ff10f8d6c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5113.345215, idle connection 410452.000000, request 304999.956369
10/27/2025 02:03:45.040 7ff11032dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296928.364746, idle connection 410107.000000, request 304998.751879
10/27/2025 02:03:45.040 7ff10f8d6c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5112.550293, idle connection 410451.000000, request 304999.166012
10/27/2025 02:03:45.043 7ff10f8d6f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6213.768555, idle connection 408740.000000, request 304399.195910
10/27/2025 02:03:45.044 7ff10f8d6f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1000
10/27/2025 02:03:45.044 7ff10f8d6f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:45.044 7ff10f8d6f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 1000 (601.2575626373291 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=841159033, topics=[])
10/27/2025 02:03:45.044 7ff10f8d6f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 841159033 with 0 response partitions (1 implied)
10/27/2025 02:03:45.046 7ff110fe8400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4636.941650, idle connection 411916.000000, request 304399.279833
10/27/2025 02:03:45.046 7ff110fe8400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1061
10/27/2025 02:03:45.046 7ff110fe8400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:45.046 7ff110fe8400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 1061 (601.1147499084473 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=964621859, topics=[])
10/27/2025 02:03:45.046 7ff110fe8400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 964621859 with 0 response partitions (1 implied)
10/27/2025 02:03:45.049 7ff10f8d6e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 33
10/27/2025 02:03:45.049 7ff10f8d6e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)}
10/27/2025 02:03:45.049 7ff10f8d6e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff10f77c8b0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)])
10/27/2025 02:03:45.049 7ff10f8d6e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/27/2025 02:03:45.049 7ff10f8d6e00 [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=1529001951, session_epoch=1004, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.049 7ff10f8d6e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 1009 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1529001951, session_epoch=1004, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.049 7ff10f8d6e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5708.876953, idle connection 410443.000000, request 304999.955654
10/27/2025 02:03:45.049 7ff10ffd92c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0
10/27/2025 02:03:45.050 7ff10ffd92c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)}
10/27/2025 02:03:45.050 7ff10ffd92c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff10f7abc70> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)])
10/27/2025 02:03:45.050 7ff10ffd92c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/27/2025 02:03:45.050 7ff10ffd92c0 [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=15594906, session_epoch=990, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.050 7ff10ffd92c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 995 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=15594906, session_epoch=990, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.050 7ff10ffd92c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5107.991699, idle connection 410442.000000, request 304999.961376
10/27/2025 02:03:45.050 7ff10ffd95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5263.723389, idle connection 409594.000000, request 304397.060633
10/27/2025 02:03:45.051 7ff10f8d6e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5707.623535, idle connection 410441.000000, request 304998.705864
10/27/2025 02:03:45.051 7ff10ffd95e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1049
10/27/2025 02:03:45.051 7ff10ffd95e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:45.051 7ff10ffd95e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 1049 (603.7342548370361 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=324115869, topics=[])
10/27/2025 02:03:45.051 7ff10ffd95e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 324115869 with 0 response partitions (1 implied)
10/27/2025 02:03:45.051 7ff10ffd92c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5106.479248, idle connection 410441.000000, request 304998.452902
10/27/2025 02:03:45.136 7ff10ffd9400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 0
10/27/2025 02:03:45.136 7ff10ffd9400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)}
10/27/2025 02:03:45.136 7ff10ffd9400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff10f7d03a0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)])
10/27/2025 02:03:45.137 7ff10ffd9400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/27/2025 02:03:45.137 7ff10ffd9400 [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=639597569, session_epoch=990, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.137 7ff10ffd9400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 995 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=639597569, session_epoch=990, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.137 7ff10ffd9400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5022.830811, idle connection 409210.000000, request 304999.945164
10/27/2025 02:03:45.137 7ff10ffd9400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5022.367920, idle connection 409209.000000, request 304999.489784
10/27/2025 02:03:45.148 7ff110fe80e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 125
10/27/2025 02:03:45.148 7ff110fe80e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)}
10/27/2025 02:03:45.148 7ff110fe80e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff10f892ca0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)])
10/27/2025 02:03:45.148 7ff110fe80e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/27/2025 02:03:45.148 7ff110fe80e0 [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=698517486, session_epoch=1033, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.148 7ff110fe80e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 1039 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=698517486, session_epoch=1033, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.148 7ff110fe80e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298195.078125, idle connection 410831.000000, request 304999.946833
10/27/2025 02:03:45.149 7ff11032d180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 19
10/27/2025 02:03:45.149 7ff11032d180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)}
10/27/2025 02:03:45.149 7ff11032d180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff10f77c730> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)])
10/27/2025 02:03:45.149 7ff11032d180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/27/2025 02:03:45.149 7ff11032d180 [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=1436001488, session_epoch=997, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.149 7ff11032d180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 1002 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1436001488, session_epoch=997, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.149 7ff11032d180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5325.735840, idle connection 410452.000000, request 304999.960661
10/27/2025 02:03:45.150 7ff110fe80e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298193.917725, idle connection 410830.000000, request 304998.794556
10/27/2025 02:03:45.150 7ff11032d180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5324.971436, idle connection 410451.000000, request 304999.201059
10/27/2025 02:03:45.157 7ff11032d400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7127.464111, idle connection 409834.000000, request 304398.966074
10/27/2025 02:03:45.157 7ff11032d400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1003
10/27/2025 02:03:45.157 7ff11032d400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:45.157 7ff11032d400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 1003 (601.60231590271 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1459049024, topics=[])
10/27/2025 02:03:45.157 7ff11032d400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1459049024 with 0 response partitions (1 implied)
10/27/2025 02:03:45.159 7ff110688e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4944.413086, idle connection 410741.000000, request 304399.096489
10/27/2025 02:03:45.160 7ff110688e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1015
10/27/2025 02:03:45.160 7ff110688e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:45.160 7ff110688e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 1015 (601.3679504394531 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1075489024, topics=[])
10/27/2025 02:03:45.160 7ff110688e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1075489024 with 0 response partitions (1 implied)
10/27/2025 02:03:45.162 7ff1106a7540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 18
10/27/2025 02:03:45.163 7ff1106a7540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)}
10/27/2025 02:03:45.163 7ff1106a7540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff10f7f0610> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)])
10/27/2025 02:03:45.163 7ff1106a7540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/27/2025 02:03:45.163 7ff1106a7540 [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=133203326, session_epoch=994, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.163 7ff1106a7540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 999 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=133203326, session_epoch=994, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.163 7ff1106a7540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7594.039307, idle connection 410444.000000, request 304999.939442
10/27/2025 02:03:45.164 7ff1106a7540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7593.552490, idle connection 410444.000000, request 304999.454498
10/27/2025 02:03:45.167 7ff1106a7040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 72
10/27/2025 02:03:45.167 7ff1106a7040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)}
10/27/2025 02:03:45.167 7ff1106a7040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff10f7ab310> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)])
10/27/2025 02:03:45.168 7ff1106a7040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/27/2025 02:03:45.168 7ff1106a7040 [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=287410026, session_epoch=1005, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.168 7ff1106a7040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 1010 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=287410026, session_epoch=1005, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.168 7ff1106a7040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7430.971924, idle connection 410472.000000, request 304999.942303
10/27/2025 02:03:45.168 7ff110736d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 100
10/27/2025 02:03:45.168 7ff110736d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)}
10/27/2025 02:03:45.168 7ff110736d60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff10f85e190> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)])
10/27/2025 02:03:45.168 7ff110736d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/27/2025 02:03:45.168 7ff110736d60 [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=1881521534, session_epoch=1021, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.169 7ff110736d60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 1026 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1881521534, session_epoch=1021, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.169 7ff110736d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5301.273926, idle connection 409368.000000, request 304999.963284
10/27/2025 02:03:45.169 7ff1106a7040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 7429.876465, idle connection 410471.000000, request 304998.851061
10/27/2025 02:03:45.169 7ff1107df220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 3751.324219, idle connection 409836.000000, request 304395.120144
10/27/2025 02:03:45.169 7ff11032d540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4836.161377, idle connection 409906.000000, request 304395.668030
10/27/2025 02:03:45.170 7ff110fe84a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 297579.313721, idle connection 411182.000000, request 304396.164417
10/27/2025 02:03:45.170 7ff110736d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5300.086670, idle connection 409367.000000, request 304998.779535
10/27/2025 02:03:45.170 7ff1107df220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 998
10/27/2025 02:03:45.170 7ff1107df220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:45.170 7ff1107df220 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 998 (606.0059070587158 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=416559494, topics=[])
10/27/2025 02:03:45.171 7ff1107df220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 416559494 with 0 response partitions (1 implied)
10/27/2025 02:03:45.171 7ff11032d540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1004
10/27/2025 02:03:45.171 7ff11032d540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:45.171 7ff11032d540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 1004 (605.8633327484131 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1284441667, topics=[])
10/27/2025 02:03:45.171 7ff11032d540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1284441667 with 0 response partitions (1 implied)
10/27/2025 02:03:45.171 7ff110fe84a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1069
10/27/2025 02:03:45.171 7ff110fe84a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:45.171 7ff110fe84a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 1069 (605.766773223877 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2070676963, topics=[])
10/27/2025 02:03:45.172 7ff110fe84a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2070676963 with 0 response partitions (1 implied)
10/27/2025 02:03:45.212 7ff11032d720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 336
10/27/2025 02:03:45.212 7ff11032d720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)}
10/27/2025 02:03:45.212 7ff11032d720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff10f86c880> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)])
10/27/2025 02:03:45.212 7ff11032d720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/27/2025 02:03:45.213 7ff11032d720 [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=1722810103, session_epoch=1061, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.213 7ff11032d720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 1067 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1722810103, session_epoch=1061, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.213 7ff11032d720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298193.994141, idle connection 410543.000000, request 304999.942303
10/27/2025 02:03:45.213 7ff11032d720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 298193.411865, idle connection 410542.000000, request 304999.371290
10/27/2025 02:03:45.276 7ff110fe8180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 434
10/27/2025 02:03:45.276 7ff110fe8180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)}
10/27/2025 02:03:45.276 7ff110fe8180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff10f77c850> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)])
10/27/2025 02:03:45.276 7ff110fe8180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/27/2025 02:03:45.277 7ff110fe8180 [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=839569081, session_epoch=1091, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.277 7ff110fe8180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 1097 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=839569081, session_epoch=1091, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.277 7ff110fe8180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296992.328369, idle connection 411713.000000, request 304999.925852
10/27/2025 02:03:45.277 7ff110fe8180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296991.773438, idle connection 411712.000000, request 304999.385834
10/27/2025 02:03:45.354 7ff11032db80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 297589.465820, idle connection 409943.000000, request 304396.558046
10/27/2025 02:03:45.354 7ff11032db80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1026
10/27/2025 02:03:45.354 7ff11032db80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:45.354 7ff11032db80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 1026 (604.093074798584 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1584751795, topics=[])
10/27/2025 02:03:45.354 7ff11032db80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1584751795 with 0 response partitions (1 implied)
10/27/2025 02:03:45.369 7ff1106dea40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 3681.348633, idle connection 410336.000000, request 304398.900032
10/27/2025 02:03:45.370 7ff1106dea40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1486
10/27/2025 02:03:45.370 7ff1106dea40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:45.370 7ff1106dea40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 1486 (601.6600131988525 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=748358585, topics=[])
10/27/2025 02:03:45.370 7ff1106dea40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 748358585 with 0 response partitions (1 implied)
10/27/2025 02:03:45.455 7ff11032de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296385.056396, idle connection 411388.000000, request 304396.158218
10/27/2025 02:03:45.456 7ff11032de00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1039
10/27/2025 02:03:45.456 7ff11032de00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:45.456 7ff11032de00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 1039 (604.5734882354736 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=356595921, topics=[])
10/27/2025 02:03:45.457 7ff11032de00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 356595921 with 0 response partitions (1 implied)
10/27/2025 02:03:45.458 7ff1106de2c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5489.807861, idle connection 411045.000000, request 304394.638777
10/27/2025 02:03:45.458 7ff11032dea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296387.329590, idle connection 411702.000000, request 304395.088196
10/27/2025 02:03:45.458 7ff1106de2c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1010
10/27/2025 02:03:45.459 7ff1106de2c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:45.459 7ff1106de2c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 1010 (606.3361167907715 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2054903511, topics=[])
10/27/2025 02:03:45.459 7ff1106de2c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2054903511 with 0 response partitions (1 implied)
10/27/2025 02:03:45.459 7ff11032dea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1068
10/27/2025 02:03:45.460 7ff11032dea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:45.460 7ff11032dea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 1068 (606.4808368682861 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1108008487, topics=[])
10/27/2025 02:03:45.460 7ff11032dea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1108008487 with 0 response partitions (1 implied)
10/27/2025 02:03:45.460 7ff1106eb7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 52
10/27/2025 02:03:45.460 7ff1106eb7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)}
10/27/2025 02:03:45.460 7ff1106eb7c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff10f82a490> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)])
10/27/2025 02:03:45.460 7ff1106eb7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/27/2025 02:03:45.461 7ff1106eb7c0 [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=1223561683, session_epoch=1000, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.461 7ff1106eb7c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 1005 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1223561683, session_epoch=1000, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.462 7ff1106eb7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5931.146484, idle connection 410387.000000, request 304999.934912
10/27/2025 02:03:45.462 7ff1106eb7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5930.648438, idle connection 410386.000000, request 304999.445200
10/27/2025 02:03:45.462 7ff10f8d6cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 22
10/27/2025 02:03:45.463 7ff10f8d6cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)}
10/27/2025 02:03:45.463 7ff10f8d6cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff10f7ab520> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)])
10/27/2025 02:03:45.463 7ff10f8d6cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/27/2025 02:03:45.463 7ff10f8d6cc0 [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=1049378430, session_epoch=999, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.463 7ff10f8d6cc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 1004 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1049378430, session_epoch=999, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.463 7ff10f8d6cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 3628.388916, idle connection 409310.000000, request 304999.958515
10/27/2025 02:03:45.463 7ff110767540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 23
10/27/2025 02:03:45.463 7ff110767540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)}
10/27/2025 02:03:45.463 7ff110767540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff10f77cdc0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)])
10/27/2025 02:03:45.464 7ff110767540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/27/2025 02:03:45.464 7ff110767540 [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=1731228986, session_epoch=997, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.464 7ff110767540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 1002 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1731228986, session_epoch=997, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.464 7ff110767540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4388.052979, idle connection 409638.000000, request 304999.963045
10/27/2025 02:03:45.464 7ff11032df40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296382.950439, idle connection 410364.000000, request 304396.521091
10/27/2025 02:03:45.464 7ff10f8d6cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 3627.024658, idle connection 409309.000000, request 304998.597145
10/27/2025 02:03:45.465 7ff11032df40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1066
10/27/2025 02:03:45.465 7ff11032df40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:45.466 7ff11032df40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 1066 (605.1695346832275 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2460895, topics=[])
10/27/2025 02:03:45.466 7ff11032df40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2460895 with 0 response partitions (1 implied)
10/27/2025 02:03:45.466 7ff110767540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4385.447266, idle connection 409636.000000, request 304997.359037
10/27/2025 02:03:45.469 7ff1106a7ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6347.923828, idle connection 410008.000000, request 304398.784637
10/27/2025 02:03:45.470 7ff1106a7ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1001
10/27/2025 02:03:45.470 7ff1106a7ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:45.470 7ff1106a7ea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 1001 (601.7026901245117 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=702775847, topics=[])
10/27/2025 02:03:45.470 7ff1106a7ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 702775847 with 0 response partitions (1 implied)
10/27/2025 02:03:45.641 7ff11032dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296327.546387, idle connection 409506.000000, request 304397.923470
10/27/2025 02:03:45.641 7ff11032dc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1061
10/27/2025 02:03:45.641 7ff11032dc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:45.641 7ff11032dc20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 1061 (602.7066707611084 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=29594918, topics=[])
10/27/2025 02:03:45.642 7ff11032dc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 29594918 with 0 response partitions (1 implied)
10/27/2025 02:03:45.642 7ff10f8d6c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4511.014648, idle connection 409849.000000, request 304397.627115
10/27/2025 02:03:45.642 7ff10f8d6c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 996
10/27/2025 02:03:45.642 7ff10f8d6c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:45.642 7ff10f8d6c20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 996 (602.7460098266602 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1840096657, topics=[])
10/27/2025 02:03:45.642 7ff10f8d6c20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1840096657 with 0 response partitions (1 implied)
10/27/2025 02:03:45.644 7ff10f8d6f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 26
10/27/2025 02:03:45.644 7ff10f8d6f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)}
10/27/2025 02:03:45.645 7ff10f8d6f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff10f773ca0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)])
10/27/2025 02:03:45.645 7ff10f8d6f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/27/2025 02:03:45.645 7ff10f8d6f40 [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=841159033, session_epoch=996, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.645 7ff10f8d6f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 1001 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=841159033, session_epoch=996, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.645 7ff10f8d6f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5612.278076, idle connection 408138.000000, request 304999.952555
10/27/2025 02:03:45.646 7ff10f8d6f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5611.691162, idle connection 408138.000000, request 304999.368191
10/27/2025 02:03:45.647 7ff110fe8400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 296
10/27/2025 02:03:45.647 7ff110fe8400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)}
10/27/2025 02:03:45.647 7ff110fe8400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff10f86cd90> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)])
10/27/2025 02:03:45.647 7ff110fe8400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/27/2025 02:03:45.647 7ff110fe8400 [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=964621859, session_epoch=1057, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.647 7ff110fe8400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 1062 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=964621859, session_epoch=1057, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.647 7ff110fe8400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4035.382812, idle connection 411314.000000, request 304999.951839
10/27/2025 02:03:45.649 7ff110fe8400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4034.260742, idle connection 411313.000000, request 304998.834848
10/27/2025 02:03:45.651 7ff10ffd95e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 266
10/27/2025 02:03:45.652 7ff10ffd95e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)}
10/27/2025 02:03:45.652 7ff10ffd95e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff10f77d610> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)])
10/27/2025 02:03:45.652 7ff10ffd95e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/27/2025 02:03:45.652 7ff10ffd95e0 [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=324115869, session_epoch=1045, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.652 7ff10ffd95e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 1050 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=324115869, session_epoch=1045, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.652 7ff10ffd95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4661.837402, idle connection 408992.000000, request 304999.953270
10/27/2025 02:03:45.652 7ff10f8d6e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 5105.822998, idle connection 409840.000000, request 304396.902561
10/27/2025 02:03:45.652 7ff10ffd92c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4505.483154, idle connection 409840.000000, request 304397.454977
10/27/2025 02:03:45.653 7ff10ffd95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4661.031250, idle connection 408991.000000, request 304999.153137
10/27/2025 02:03:45.653 7ff10f8d6e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1009
10/27/2025 02:03:45.653 7ff10f8d6e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:45.653 7ff10f8d6e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 1009 (604.0303707122803 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1529001951, topics=[])
10/27/2025 02:03:45.653 7ff10f8d6e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1529001951 with 0 response partitions (1 implied)
10/27/2025 02:03:45.654 7ff10ffd92c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 995
10/27/2025 02:03:45.654 7ff10ffd92c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:45.654 7ff10ffd92c0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 995 (603.8329601287842 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=15594906, topics=[])
10/27/2025 02:03:45.654 7ff10ffd92c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 15594906 with 0 response partitions (1 implied)
10/27/2025 02:03:45.739 7ff10ffd9400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4420.763672, idle connection 408608.000000, request 304397.876978
10/27/2025 02:03:45.740 7ff10ffd9400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 995
10/27/2025 02:03:45.740 7ff10ffd9400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:45.740 7ff10ffd9400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 995 (602.8671264648438 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=639597569, topics=[])
10/27/2025 02:03:45.740 7ff10ffd9400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 639597569 with 0 response partitions (1 implied)
10/27/2025 02:03:45.751 7ff110fe80e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 297592.224609, idle connection 410228.000000, request 304397.090912
10/27/2025 02:03:45.752 7ff110fe80e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1039
10/27/2025 02:03:45.752 7ff110fe80e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:45.752 7ff110fe80e0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 1039 (603.5139560699463 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=698517486, topics=[])
10/27/2025 02:03:45.752 7ff110fe80e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 698517486 with 0 response partitions (1 implied)
10/27/2025 02:03:45.752 7ff11032d180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4722.466797, idle connection 409848.000000, request 304396.691799
10/27/2025 02:03:45.753 7ff11032d180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1002
10/27/2025 02:03:45.753 7ff11032d180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:45.753 7ff11032d180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 1002 (603.7681102752686 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1436001488, topics=[])
10/27/2025 02:03:45.753 7ff11032d180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1436001488 with 0 response partitions (1 implied)
10/27/2025 02:03:45.758 7ff11032d400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 32
10/27/2025 02:03:45.758 7ff11032d400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)}
10/27/2025 02:03:45.758 7ff11032d400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff10f77c460> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)])
10/27/2025 02:03:45.758 7ff11032d400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/27/2025 02:03:45.758 7ff11032d400 [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=1459049024, session_epoch=999, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.758 7ff11032d400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 1004 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1459049024, session_epoch=999, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.758 7ff11032d400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6525.546387, idle connection 409232.000000, request 304999.948978
10/27/2025 02:03:45.759 7ff11032d400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6525.047607, idle connection 409232.000000, request 304999.453783
10/27/2025 02:03:45.760 7ff110688e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 85
10/27/2025 02:03:45.760 7ff110688e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)}
10/27/2025 02:03:45.761 7ff110688e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff10f7caee0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)])
10/27/2025 02:03:45.761 7ff110688e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/27/2025 02:03:45.761 7ff110688e00 [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=1075489024, session_epoch=1011, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.761 7ff110688e00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 1016 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1075489024, session_epoch=1011, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.761 7ff110688e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4342.918213, idle connection 410140.000000, request 304999.953985
10/27/2025 02:03:45.761 7ff110688e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4342.471924, idle connection 410139.000000, request 304999.510765
10/27/2025 02:03:45.764 7ff1106a7540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6993.163330, idle connection 409843.000000, request 304399.067163
10/27/2025 02:03:45.764 7ff1106a7540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 999
10/27/2025 02:03:45.764 7ff1106a7540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:45.764 7ff1106a7540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 999 (601.4199256896973 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=133203326, topics=[])
10/27/2025 02:03:45.765 7ff1106a7540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 133203326 with 0 response partitions (1 implied)
10/27/2025 02:03:45.770 7ff1106a7040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 6828.671387, idle connection 409869.000000, request 304397.639990
10/27/2025 02:03:45.771 7ff1106a7040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1010
10/27/2025 02:03:45.771 7ff1106a7040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:45.771 7ff1106a7040 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 1010 (602.8778553009033 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=287410026, topics=[])
10/27/2025 02:03:45.771 7ff1106a7040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 287410026 with 0 response partitions (1 implied)
10/27/2025 02:03:45.771 7ff1107df220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 9
10/27/2025 02:03:45.771 7ff1107df220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)}
10/27/2025 02:03:45.771 7ff1107df220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff10f7ca580> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)])
10/27/2025 02:03:45.771 7ff1107df220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/27/2025 02:03:45.771 7ff1107df220 [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=416559494, session_epoch=994, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.772 7ff1107df220 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 999 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=416559494, session_epoch=994, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.772 7ff1107df220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 3148.912354, idle connection 409234.000000, request 304999.958754
10/27/2025 02:03:45.772 7ff11032d540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 32
10/27/2025 02:03:45.772 7ff11032d540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)}
10/27/2025 02:03:45.772 7ff11032d540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff10f7ebf70> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)])
10/27/2025 02:03:45.772 7ff11032d540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/27/2025 02:03:45.772 7ff11032d540 [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=1284441667, session_epoch=1000, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.772 7ff11032d540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 1005 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1284441667, session_epoch=1000, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.772 7ff11032d540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4233.242432, idle connection 409303.000000, request 304999.964714
10/27/2025 02:03:45.772 7ff110fe84a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 396
10/27/2025 02:03:45.773 7ff110fe84a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)}
10/27/2025 02:03:45.773 7ff110fe84a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7ff10f7d0730> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)])
10/27/2025 02:03:45.773 7ff110fe84a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/27/2025 02:03:45.773 7ff110fe84a0 [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=2070676963, session_epoch=1064, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.773 7ff110fe84a0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Request 1070 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2070676963, session_epoch=1064, topics=[], forgotten_topics_data=[])
10/27/2025 02:03:45.773 7ff110fe84a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296975.851074, idle connection 410578.000000, request 304999.959946
10/27/2025 02:03:45.773 7ff1107df220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 3147.178711, idle connection 409232.000000, request 304998.227358
10/27/2025 02:03:45.774 7ff110736d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4696.313232, idle connection 408763.000000, request 304395.005226
10/27/2025 02:03:45.774 7ff11032d540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 4231.682861, idle connection 409301.000000, request 304998.384714
10/27/2025 02:03:45.774 7ff110fe84a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296974.641846, idle connection 410577.000000, request 304998.754263
10/27/2025 02:03:45.775 7ff110736d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1026
10/27/2025 02:03:45.775 7ff110736d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:45.775 7ff110736d60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 1026 (606.0636043548584 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1881521534, topics=[])
10/27/2025 02:03:45.775 7ff110736d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1881521534 with 0 response partitions (1 implied)
10/27/2025 02:03:45.814 7ff11032d720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 297592.886719, idle connection 409942.000000, request 304398.837566
10/27/2025 02:03:45.814 7ff11032d720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1067
10/27/2025 02:03:45.814 7ff11032d720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:45.815 7ff11032d720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 1067 (601.783037185669 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1722810103, topics=[])
10/27/2025 02:03:45.815 7ff11032d720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1722810103 with 0 response partitions (1 implied)
10/27/2025 02:03:45.878 7ff110fe8180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 296391.115967, idle connection 411112.000000, request 304398.718119
10/27/2025 02:03:45.878 7ff110fe8180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1097
10/27/2025 02:03:45.879 7ff110fe8180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/27/2025 02:03:45.879 7ff110fe8180 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.27:9092 <connected> [IPv4 ('10.0.0.27', 9092)]>: Response 1097 (601.8321514129639 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=839569081, topics=[])
10/27/2025 02:03:45.879 7ff110fe8180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 839569081 with 0 response partitions (1 implied)