06/19/2025 02:34:21.813 7f41a28d8ac8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2134
06/19/2025 02:34:21.815 7f41a28d8ac8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
06/19/2025 02:34:21.815 7f41a28d8ac8 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 2134 (603.4202575683594 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=928883267, topics=[])
06/19/2025 02:34:21.815 7f41a28d8ac8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 928883267 with 0 response partitions (1 implied)
06/19/2025 02:34:21.815 7f41a27da780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 138508.573486, idle connection 127885.000000, request 304396.858692
06/19/2025 02:34:21.815 7f41a294d8d0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 138511.058105, idle connection 126685.000000, request 304398.068190
06/19/2025 02:34:21.816 7f41a27da780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2134
06/19/2025 02:34:21.816 7f41a27da780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
06/19/2025 02:34:21.816 7f41a27da780 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 2134 (603.6386489868164 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=256897991, topics=[])
06/19/2025 02:34:21.816 7f41a27da780 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 256897991 with 0 response partitions (1 implied)
06/19/2025 02:34:21.816 7f41a294d8d0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2134
06/19/2025 02:34:21.816 7f41a294d8d0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
06/19/2025 02:34:21.816 7f41a294d8d0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 2134 (602.8115749359131 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1011585424, topics=[])
06/19/2025 02:34:21.816 7f41a294d8d0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1011585424 with 0 response partitions (1 implied)
06/19/2025 02:34:21.820 7f41a243af60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 144524.558594, idle connection 127881.000000, request 304399.325848
06/19/2025 02:34:21.820 7f41a243af60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2129
06/19/2025 02:34:21.820 7f41a243af60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
06/19/2025 02:34:21.820 7f41a243af60 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 2129 (601.0103225708008 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1882259261, topics=[])
06/19/2025 02:34:21.820 7f41a243af60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1882259261 with 0 response partitions (1 implied)
06/19/2025 02:34:21.856 7f41a28d0780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 138473.853760, idle connection 126666.000000, request 304397.474289
06/19/2025 02:34:21.857 7f41a28d0780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2134
06/19/2025 02:34:21.857 7f41a28d0780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
06/19/2025 02:34:21.857 7f41a28d0780 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 2134 (602.9722690582275 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1218307599, topics=[])
06/19/2025 02:34:21.857 7f41a28d0780 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1218307599 with 0 response partitions (1 implied)
06/19/2025 02:34:21.858 7f41a79f1780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 138494.091797, idle connection 127868.000000, request 304396.558046
06/19/2025 02:34:21.858 7f41a79f1780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2134
06/19/2025 02:34:21.858 7f41a79f1780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
06/19/2025 02:34:21.858 7f41a79f1780 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 2134 (603.7993431091309 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=130490730, topics=[])
06/19/2025 02:34:21.858 7f41a79f1780 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 130490730 with 0 response partitions (1 implied)
06/19/2025 02:34:21.859 7f41a2499588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 143322.578857, idle connection 126741.000000, request 304396.903753
06/19/2025 02:34:21.859 7f41a2499588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2130
06/19/2025 02:34:21.859 7f41a2499588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
06/19/2025 02:34:21.859 7f41a2499588 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 2130 (603.4140586853027 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=8090414, topics=[])
06/19/2025 02:34:21.859 7f41a2499588 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 8090414 with 0 response partitions (1 implied)
06/19/2025 02:34:21.859 7f41a27cc780 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 138520.356689, idle connection 127970.000000, request 304397.374392
06/19/2025 02:34:21.859 7f41a2432630 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 138165.457764, idle connection 127364.000000, request 304397.863865
06/19/2025 02:34:21.860 7f41a27cc780 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2134
06/19/2025 02:34:21.860 7f41a27cc780 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
06/19/2025 02:34:21.860 7f41a27cc780 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 2134 (603.085994720459 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1099162812, topics=[])
06/19/2025 02:34:21.860 7f41a27cc780 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1099162812 with 0 response partitions (1 implied)
06/19/2025 02:34:21.860 7f41a2432630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2174
06/19/2025 02:34:21.860 7f41a2432630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
06/19/2025 02:34:21.860 7f41a2432630 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Response 2174 (602.9584407806396 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=324806933, topics=[])
06/19/2025 02:34:21.860 7f41a2432630 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 324806933 with 0 response partitions (1 implied)
06/19/2025 02:34:21.868 7f41a2ac6e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 0
06/19/2025 02:34:21.868 7f41a2ac6e10 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)}
06/19/2025 02:34:21.868 7f41a2ac6e10 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f419fb16208> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)])
06/19/2025 02:34:21.868 7f41a2ac6e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
06/19/2025 02:34:21.868 7f41a2ac6e10 [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=942418438, session_epoch=2120, topics=[], forgotten_topics_data=[])
06/19/2025 02:34:21.868 7f41a2ac6e10 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 2130 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=942418438, session_epoch=2120, topics=[], forgotten_topics_data=[])
06/19/2025 02:34:21.868 7f41a2ac6e10 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 143916.300537, idle connection 127315.000000, request 304999.953270
06/19/2025 02:34:21.868 7f41a2aa56d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 0
06/19/2025 02:34:21.868 7f41a2aa56d8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)}
06/19/2025 02:34:21.869 7f41a2aa56d8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7f419fd71ef0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)])
06/19/2025 02:34:21.869 7f41a2aa56d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
06/19/2025 02:34:21.869 7f41a2aa56d8 [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=1213240388, session_epoch=2125, topics=[], forgotten_topics_data=[])
06/19/2025 02:34:21.869 7f41a2aa56d8 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.22:9092 <connected> [IPv4 ('10.0.0.22', 9092)]>: Request 2135 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1213240388, session_epoch=2125, topics=[], forgotten_topics_data=[])
06/19/2025 02:34:21.869 7f41a2aa56d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 137907.401123, idle connection 127343.000000, request 304999.958754
06/19/2025 02:34:21.869 7f41a2ac6e10 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 143915.240967, idle connection 127314.000000, request 304998.896360
06/19/2025 02:34:21.870 7f41a2aa56d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 137906.709717, idle connection 127342.000000, request 304999.270439