03/26/2026 06:21:21.286 7fd6835ad720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)}
03/26/2026 06:21:21.288 7fd6835ad720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fd683272400> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)])
03/26/2026 06:21:21.288 7fd6835ad720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/26/2026 06:21:21.289 7fd6835ad720 [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=1466748887, session_epoch=1841, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:21.289 7fd6835ad720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Request 1843 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1466748887, session_epoch=1841, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:21.289 7fd6835ad720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37334.252197, idle connection 516196.000000, request 304999.914646
03/26/2026 06:21:21.290 7fd6835ad720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37333.678467, idle connection 516195.000000, request 304999.354124
03/26/2026 06:21:21.386 7fd6835ad900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 38769.187256, idle connection 517193.000000, request 304398.784161
03/26/2026 06:21:21.386 7fd6835ad900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1935
03/26/2026 06:21:21.386 7fd6835ad900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/26/2026 06:21:21.386 7fd6835ad900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Response 1935 (601.9992828369141 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=616132365, topics=[])
03/26/2026 06:21:21.387 7fd6835ad900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 616132365 with 0 response partitions (1 implied)
03/26/2026 06:21:21.408 7fd684b4af40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 216
03/26/2026 06:21:21.409 7fd684b4af40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)}
03/26/2026 06:21:21.409 7fd684b4af40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fd683458a90> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)])
03/26/2026 06:21:21.409 7fd684b4af40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/26/2026 06:21:21.409 7fd684b4af40 [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=19046972, session_epoch=1755, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:21.409 7fd684b4af40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Request 1758 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=19046972, session_epoch=1755, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:21.409 7fd684b4af40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 39666.523682, idle connection 279664.000000, request 304999.947786
03/26/2026 06:21:21.410 7fd684b4af40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 39666.097168, idle connection 279664.000000, request 304999.422312
03/26/2026 06:21:21.430 7fd686b44540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 1187
03/26/2026 06:21:21.430 7fd686b44540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)}
03/26/2026 06:21:21.430 7fd686b44540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fd683458ac0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)])
03/26/2026 06:21:21.430 7fd686b44540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/26/2026 06:21:21.431 7fd686b44540 [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=2004697394, session_epoch=1861, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:21.431 7fd686b44540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Request 1862 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2004697394, session_epoch=1861, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:21.431 7fd686b44540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37544.617188, idle connection 277541.000000, request 304999.947071
03/26/2026 06:21:21.431 7fd686b44540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37544.180908, idle connection 277541.000000, request 304999.518394
03/26/2026 06:21:21.501 7fd684b4a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 38751.412842, idle connection 518120.000000, request 304398.875237
03/26/2026 06:21:21.501 7fd684b4a720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1839
03/26/2026 06:21:21.501 7fd684b4a720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/26/2026 06:21:21.501 7fd684b4a720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Response 1839 (601.6740798950195 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=990524129, topics=[])
03/26/2026 06:21:21.501 7fd684b4a720 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 990524129 with 0 response partitions (1 implied)
03/26/2026 06:21:21.583 7fd684b4ac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37607.433838, idle connection 453518.000000, request 304398.787022
03/26/2026 06:21:21.583 7fd684b4ac20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1756
03/26/2026 06:21:21.583 7fd684b4ac20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/26/2026 06:21:21.584 7fd684b4ac20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Response 1756 (601.7508506774902 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1195686410, topics=[])
03/26/2026 06:21:21.584 7fd684b4ac20 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1195686410 with 0 response partitions (1 implied)
03/26/2026 06:21:21.609 7fd684b4a680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 1001
03/26/2026 06:21:21.609 7fd684b4a680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)}
03/26/2026 06:21:21.609 7fd684b4a680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fd683295730> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)])
03/26/2026 06:21:21.609 7fd684b4a680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/26/2026 06:21:21.609 7fd684b4a680 [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=902623053, session_epoch=2190, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:21.610 7fd684b4a680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 2223 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=902623053, session_epoch=2190, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:21.610 7fd684b4a680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 46526.606689, idle connection 224114.000000, request 304999.946356
03/26/2026 06:21:21.610 7fd684b4a680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 46526.090820, idle connection 224114.000000, request 304999.437094
03/26/2026 06:21:21.682 7fd684b4ae00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 17
03/26/2026 06:21:21.682 7fd684b4ae00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)}
03/26/2026 06:21:21.683 7fd684b4ae00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fd683293a90> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)])
03/26/2026 06:21:21.683 7fd684b4ae00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/26/2026 06:21:21.683 7fd684b4ae00 [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=40050549, session_epoch=1959, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:21.683 7fd684b4ae00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 1965 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=40050549, session_epoch=1959, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:21.683 7fd684b4ae00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 43906.044434, idle connection 283903.000000, request 304999.945164
03/26/2026 06:21:21.683 7fd684b4ae00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 43905.626221, idle connection 283903.000000, request 304999.534369
03/26/2026 06:21:21.691 7fd686b44900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36894.804932, idle connection 276893.000000, request 304399.085522
03/26/2026 06:21:21.691 7fd686b44900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1774
03/26/2026 06:21:21.691 7fd686b44900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/26/2026 06:21:21.692 7fd686b44900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Response 1774 (601.3915538787842 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1242907814, topics=[])
03/26/2026 06:21:21.692 7fd686b44900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1242907814 with 0 response partitions (1 implied)
03/26/2026 06:21:21.807 7fd684b4a900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 18
03/26/2026 06:21:21.807 7fd684b4a900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)}
03/26/2026 06:21:21.807 7fd684b4a900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fd6842c0190> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)])
03/26/2026 06:21:21.807 7fd684b4a900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/26/2026 06:21:21.807 7fd684b4a900 [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=714781556, session_epoch=1713, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:21.808 7fd684b4a900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Request 1716 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=714781556, session_epoch=1713, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:21.808 7fd684b4a900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 39060.626709, idle connection 279058.000000, request 304999.947309
03/26/2026 06:21:21.808 7fd684b4acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36817.061279, idle connection 515888.000000, request 304396.890640
03/26/2026 06:21:21.808 7fd684b4a900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 39060.001953, idle connection 279057.000000, request 304999.331951
03/26/2026 06:21:21.808 7fd684b4acc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1723
03/26/2026 06:21:21.809 7fd684b4acc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/26/2026 06:21:21.809 7fd684b4acc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Response 1723 (603.8088798522949 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=879405966, topics=[])
03/26/2026 06:21:21.809 7fd684b4acc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 879405966 with 0 response partitions (1 implied)
03/26/2026 06:21:21.878 7fd6837d9a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 43516.981445, idle connection 283513.000000, request 304398.720264
03/26/2026 06:21:21.879 7fd6837d9a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 3192
03/26/2026 06:21:21.879 7fd6837d9a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/26/2026 06:21:21.879 7fd6837d9a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 3192 (601.9177436828613 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1021309874, topics=[])
03/26/2026 06:21:21.879 7fd6837d9a40 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1021309874 with 0 response partitions (1 implied)
03/26/2026 06:21:21.890 7fd6835ad720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36732.916016, idle connection 515595.000000, request 304398.586988
03/26/2026 06:21:21.891 7fd6835ad720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1843
03/26/2026 06:21:21.891 7fd6835ad720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/26/2026 06:21:21.891 7fd6835ad720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Response 1843 (602.0205020904541 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1466748887, topics=[])
03/26/2026 06:21:21.891 7fd6835ad720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1466748887 with 0 response partitions (1 implied)
03/26/2026 06:21:21.987 7fd6835ad900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 1486
03/26/2026 06:21:21.987 7fd6835ad900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)}
03/26/2026 06:21:21.988 7fd6835ad900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fd683466e20> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)])
03/26/2026 06:21:21.988 7fd6835ad900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/26/2026 06:21:21.988 7fd6835ad900 [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=616132365, session_epoch=1932, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:21.988 7fd6835ad900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Request 1936 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=616132365, session_epoch=1932, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:21.988 7fd6835ad900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 38166.739502, idle connection 516591.000000, request 304999.945879
03/26/2026 06:21:21.988 7fd6835ad900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 38166.338135, idle connection 516591.000000, request 304999.549627
03/26/2026 06:21:22.010 7fd684b4af40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 39065.325684, idle connection 279063.000000, request 304398.748636
03/26/2026 06:21:22.011 7fd684b4af40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1758
03/26/2026 06:21:22.011 7fd684b4af40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/26/2026 06:21:22.011 7fd684b4af40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Response 1758 (601.7718315124512 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=19046972, topics=[])
03/26/2026 06:21:22.011 7fd684b4af40 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 19046972 with 0 response partitions (1 implied)
03/26/2026 06:21:22.032 7fd686b44540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36943.659424, idle connection 276940.000000, request 304398.985386
03/26/2026 06:21:22.032 7fd686b44540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1862
03/26/2026 06:21:22.032 7fd686b44540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/26/2026 06:21:22.032 7fd686b44540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Response 1862 (601.590633392334 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2004697394, topics=[])
03/26/2026 06:21:22.033 7fd686b44540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2004697394 with 0 response partitions (1 implied)
03/26/2026 06:21:22.102 7fd684b4a720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 825
03/26/2026 06:21:22.103 7fd684b4a720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)}
03/26/2026 06:21:22.103 7fd684b4a720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fd683329eb0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)])
03/26/2026 06:21:22.103 7fd684b4a720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/26/2026 06:21:22.103 7fd684b4a720 [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=990524129, session_epoch=1834, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:22.103 7fd684b4a720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Request 1840 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=990524129, session_epoch=1834, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:22.103 7fd684b4a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 38148.565918, idle connection 517517.000000, request 304999.927759
03/26/2026 06:21:22.104 7fd684b4a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 38147.922119, idle connection 517516.000000, request 304999.294519
03/26/2026 06:21:22.184 7fd684b4ac20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 174
03/26/2026 06:21:22.184 7fd684b4ac20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)}
03/26/2026 06:21:22.184 7fd684b4ac20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fd68320b9a0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)])
03/26/2026 06:21:22.185 7fd684b4ac20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/26/2026 06:21:22.185 7fd684b4ac20 [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=1195686410, session_epoch=1749, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:22.185 7fd684b4ac20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Request 1757 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1195686410, session_epoch=1749, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:22.185 7fd684b4ac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37005.227295, idle connection 452915.000000, request 304999.925852
03/26/2026 06:21:22.186 7fd684b4ac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37004.633301, idle connection 452915.000000, request 304999.342442
03/26/2026 06:21:22.213 7fd684b4a680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 45923.620605, idle connection 223511.000000, request 304396.957636
03/26/2026 06:21:22.213 7fd684b4a680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2223
03/26/2026 06:21:22.213 7fd684b4a680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/26/2026 06:21:22.213 7fd684b4a680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 2223 (603.6877632141113 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=902623053, topics=[])
03/26/2026 06:21:22.214 7fd684b4a680 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 902623053 with 0 response partitions (1 implied)
03/26/2026 06:21:22.284 7fd684b4ae00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 43304.966797, idle connection 283302.000000, request 304398.861170
03/26/2026 06:21:22.285 7fd684b4ae00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1965
03/26/2026 06:21:22.285 7fd684b4ae00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/26/2026 06:21:22.285 7fd684b4ae00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 1965 (601.935625076294 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=40050549, topics=[])
03/26/2026 06:21:22.285 7fd684b4ae00 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 40050549 with 0 response partitions (1 implied)
03/26/2026 06:21:22.293 7fd686b44900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 429
03/26/2026 06:21:22.293 7fd686b44900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)}
03/26/2026 06:21:22.293 7fd686b44900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fd683272130> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)])
03/26/2026 06:21:22.293 7fd686b44900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/26/2026 06:21:22.293 7fd686b44900 [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=1242907814, session_epoch=1772, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:22.294 7fd686b44900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Request 1775 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1242907814, session_epoch=1772, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:22.294 7fd686b44900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36292.043701, idle connection 276290.000000, request 304999.926090
03/26/2026 06:21:22.294 7fd686b44900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36291.457764, idle connection 276289.000000, request 304999.349833
03/26/2026 06:21:22.410 7fd684b4acc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 44
03/26/2026 06:21:22.410 7fd684b4acc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)}
03/26/2026 06:21:22.410 7fd684b4acc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fd68324f5b0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)])
03/26/2026 06:21:22.410 7fd684b4acc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/26/2026 06:21:22.410 7fd684b4acc0 [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=879405966, session_epoch=1720, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:22.410 7fd684b4acc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Request 1724 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=879405966, session_epoch=1720, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:22.411 7fd684b4acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36214.384766, idle connection 515285.000000, request 304999.927759
03/26/2026 06:21:22.411 7fd684b4a900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 38457.326660, idle connection 278455.000000, request 304396.650791
03/26/2026 06:21:22.411 7fd684b4acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36213.587158, idle connection 515284.000000, request 304999.141455
03/26/2026 06:21:22.412 7fd684b4a900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1716
03/26/2026 06:21:22.412 7fd684b4a900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/26/2026 06:21:22.412 7fd684b4a900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Response 1716 (604.365348815918 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=714781556, topics=[])
03/26/2026 06:21:22.412 7fd684b4a900 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 714781556 with 0 response partitions (1 implied)
03/26/2026 06:21:22.480 7fd6837d9a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 24563
03/26/2026 06:21:22.480 7fd6837d9a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)}
03/26/2026 06:21:22.480 7fd6837d9a40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fd683329be0> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)])
03/26/2026 06:21:22.481 7fd6837d9a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/26/2026 06:21:22.481 7fd6837d9a40 [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=1021309874, session_epoch=3164, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:22.481 7fd6837d9a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 3193 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1021309874, session_epoch=3164, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:22.481 7fd6837d9a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 42914.048828, idle connection 282911.000000, request 304999.924183
03/26/2026 06:21:22.482 7fd6837d9a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 42913.449463, idle connection 282910.000000, request 304999.335051
03/26/2026 06:21:22.492 7fd6835ad720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 563
03/26/2026 06:21:22.492 7fd6835ad720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)}
03/26/2026 06:21:22.492 7fd6835ad720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fd6832723a0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)])
03/26/2026 06:21:22.492 7fd6835ad720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/26/2026 06:21:22.492 7fd6835ad720 [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=1466748887, session_epoch=1842, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:22.493 7fd6835ad720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Request 1844 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1466748887, session_epoch=1842, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:22.493 7fd6835ad720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36130.497559, idle connection 514992.000000, request 304999.924898
03/26/2026 06:21:22.493 7fd6835ad720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36129.920654, idle connection 514992.000000, request 304999.357939
03/26/2026 06:21:22.589 7fd6835ad900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37565.561035, idle connection 515990.000000, request 304398.767471
03/26/2026 06:21:22.590 7fd6835ad900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1936
03/26/2026 06:21:22.590 7fd6835ad900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/26/2026 06:21:22.590 7fd6835ad900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Response 1936 (601.7646789550781 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=616132365, topics=[])
03/26/2026 06:21:22.590 7fd6835ad900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 616132365 with 0 response partitions (1 implied)
03/26/2026 06:21:22.612 7fd684b4af40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 216
03/26/2026 06:21:22.612 7fd684b4af40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)}
03/26/2026 06:21:22.612 7fd684b4af40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fd68324f700> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)])
03/26/2026 06:21:22.612 7fd684b4af40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/26/2026 06:21:22.612 7fd684b4af40 [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=19046972, session_epoch=1756, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:22.612 7fd684b4af40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Request 1759 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=19046972, session_epoch=1756, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:22.612 7fd684b4af40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 38463.452637, idle connection 278461.000000, request 304999.947548
03/26/2026 06:21:22.613 7fd684b4af40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 38463.035889, idle connection 278461.000000, request 304999.539137
03/26/2026 06:21:22.633 7fd686b44540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 1187
03/26/2026 06:21:22.633 7fd686b44540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)}
03/26/2026 06:21:22.633 7fd686b44540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fd68324f400> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)])
03/26/2026 06:21:22.633 7fd686b44540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/26/2026 06:21:22.634 7fd686b44540 [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=2004697394, session_epoch=1862, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:22.634 7fd686b44540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Request 1863 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2004697394, session_epoch=1862, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:22.634 7fd686b44540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36341.603027, idle connection 276338.000000, request 304999.924898
03/26/2026 06:21:22.634 7fd686b44540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36341.120117, idle connection 276338.000000, request 304999.458551
03/26/2026 06:21:22.705 7fd684b4a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37547.173340, idle connection 516915.000000, request 304398.540974
03/26/2026 06:21:22.705 7fd684b4a720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1840
03/26/2026 06:21:22.705 7fd684b4a720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/26/2026 06:21:22.705 7fd684b4a720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Response 1840 (602.0715236663818 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=990524129, topics=[])
03/26/2026 06:21:22.706 7fd684b4a720 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 990524129 with 0 response partitions (1 implied)
03/26/2026 06:21:22.787 7fd684b4ac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36403.627197, idle connection 452314.000000, request 304398.329020
03/26/2026 06:21:22.787 7fd684b4ac20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1757
03/26/2026 06:21:22.787 7fd684b4ac20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/26/2026 06:21:22.787 7fd684b4ac20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Response 1757 (602.3497581481934 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1195686410, topics=[])
03/26/2026 06:21:22.788 7fd684b4ac20 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1195686410 with 0 response partitions (1 implied)
03/26/2026 06:21:22.814 7fd684b4a680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 1001
03/26/2026 06:21:22.814 7fd684b4a680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)}
03/26/2026 06:21:22.814 7fd684b4a680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fd683333730> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)])
03/26/2026 06:21:22.815 7fd684b4a680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/26/2026 06:21:22.815 7fd684b4a680 [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=902623053, session_epoch=2191, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:22.815 7fd684b4a680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 2224 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=902623053, session_epoch=2191, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:22.815 7fd684b4a680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 45321.448486, idle connection 222909.000000, request 304999.936342
03/26/2026 06:21:22.815 7fd684b4a680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 45320.995117, idle connection 222909.000000, request 304999.490976
03/26/2026 06:21:22.886 7fd684b4ae00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 17
03/26/2026 06:21:22.886 7fd684b4ae00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)}
03/26/2026 06:21:22.886 7fd684b4ae00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fd6833a2d60> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)])
03/26/2026 06:21:22.886 7fd684b4ae00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/26/2026 06:21:22.886 7fd684b4ae00 [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=40050549, session_epoch=1960, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:22.887 7fd684b4ae00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 1966 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=40050549, session_epoch=1960, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:22.887 7fd684b4ae00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 42702.253906, idle connection 282699.000000, request 304999.939680
03/26/2026 06:21:22.887 7fd684b4ae00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 42701.809082, idle connection 282699.000000, request 304999.500990
03/26/2026 06:21:22.895 7fd686b44900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35690.773438, idle connection 275689.000000, request 304398.658752
03/26/2026 06:21:22.896 7fd686b44900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1775
03/26/2026 06:21:22.896 7fd686b44900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/26/2026 06:21:22.896 7fd686b44900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Response 1775 (602.013111114502 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1242907814, topics=[])
03/26/2026 06:21:22.896 7fd686b44900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1242907814 with 0 response partitions (1 implied)
03/26/2026 06:21:23.013 7fd684b4a900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 18
03/26/2026 06:21:23.013 7fd684b4a900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)}
03/26/2026 06:21:23.013 7fd684b4a900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fd6832a8550> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)])
03/26/2026 06:21:23.013 7fd684b4a900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/26/2026 06:21:23.013 7fd684b4a900 [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=714781556, session_epoch=1714, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:23.013 7fd684b4a900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Request 1717 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=714781556, session_epoch=1714, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:23.013 7fd684b4a900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37854.936768, idle connection 277852.000000, request 304999.948263
03/26/2026 06:21:23.014 7fd684b4acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35611.394043, idle connection 514682.000000, request 304396.950245
03/26/2026 06:21:23.014 7fd684b4a900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37854.316162, idle connection 277852.000000, request 304999.336481
03/26/2026 06:21:23.014 7fd684b4acc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1724
03/26/2026 06:21:23.014 7fd684b4acc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/26/2026 06:21:23.014 7fd684b4acc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Response 1724 (603.7836074829102 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=879405966, topics=[])
03/26/2026 06:21:23.015 7fd684b4acc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 879405966 with 0 response partitions (1 implied)
03/26/2026 06:21:23.082 7fd6837d9a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 42312.714600, idle connection 282309.000000, request 304398.596048
03/26/2026 06:21:23.083 7fd6837d9a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 3193
03/26/2026 06:21:23.083 7fd6837d9a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/26/2026 06:21:23.083 7fd6837d9a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 3193 (602.0205020904541 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1021309874, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=24564, last_stable_offset=24564, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00_\xf3\x00\x00\x01\x04\x00\x00\x00\x07\x02\xe7p\xe7\xb9\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])])
03/26/2026 06:21:23.083 7fd6837d9a40 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1021309874 with 1 response partitions (0 implied)
03/26/2026 06:21:23.083 7fd6837d9a40 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 24563
03/26/2026 06:21:23.084 7fd6837d9a40 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 24563 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0)
03/26/2026 06:21:23.084 7fd6837d9a40 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 24564 (leader epoch 7)
03/26/2026 06:21:23.094 7fd6835ad720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35529.328857, idle connection 514391.000000, request 304398.754597
03/26/2026 06:21:23.094 7fd6835ad720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1844
03/26/2026 06:21:23.094 7fd6835ad720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/26/2026 06:21:23.095 7fd6835ad720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Response 1844 (601.783037185669 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1466748887, topics=[])
03/26/2026 06:21:23.095 7fd6835ad720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1466748887 with 0 response partitions (1 implied)
03/26/2026 06:21:23.184 7fd6837d9a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 24564
03/26/2026 06:21:23.185 7fd6837d9a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)}
03/26/2026 06:21:23.185 7fd6837d9a40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fd683333910> for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)])
03/26/2026 06:21:23.185 7fd6837d9a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
03/26/2026 06:21:23.185 7fd6837d9a40 [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=1021309874, session_epoch=3165, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=24564, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
03/26/2026 06:21:23.185 7fd6837d9a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Request 3194 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1021309874, session_epoch=3165, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=24564, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
03/26/2026 06:21:23.185 7fd6837d9a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 42210.022949, idle connection 282206.000000, request 304999.946356
03/26/2026 06:21:23.186 7fd6837d9a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 42209.591797, idle connection 282206.000000, request 304999.523401
03/26/2026 06:21:23.190 7fd6835ad900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 1486
03/26/2026 06:21:23.190 7fd6835ad900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)}
03/26/2026 06:21:23.191 7fd6835ad900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fd6832524c0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)])
03/26/2026 06:21:23.191 7fd6835ad900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/26/2026 06:21:23.191 7fd6835ad900 [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=616132365, session_epoch=1933, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:23.191 7fd6835ad900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Request 1937 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=616132365, session_epoch=1933, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:23.191 7fd6835ad900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36963.485352, idle connection 515388.000000, request 304999.925137
03/26/2026 06:21:23.192 7fd6835ad900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36963.018311, idle connection 515387.000000, request 304999.469757
03/26/2026 06:21:23.215 7fd684b4af40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37860.499023, idle connection 277858.000000, request 304396.996737
03/26/2026 06:21:23.216 7fd684b4af40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1759
03/26/2026 06:21:23.216 7fd684b4af40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/26/2026 06:21:23.216 7fd684b4af40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Response 1759 (603.3952236175537 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=19046972, topics=[])
03/26/2026 06:21:23.216 7fd684b4af40 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 19046972 with 0 response partitions (1 implied)
03/26/2026 06:21:23.235 7fd686b44540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35740.583008, idle connection 275737.000000, request 304398.910999
03/26/2026 06:21:23.235 7fd686b44540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1863
03/26/2026 06:21:23.235 7fd686b44540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/26/2026 06:21:23.235 7fd686b44540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Response 1863 (601.6359329223633 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2004697394, topics=[])
03/26/2026 06:21:23.236 7fd686b44540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2004697394 with 0 response partitions (1 implied)
03/26/2026 06:21:23.306 7fd684b4a720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 825
03/26/2026 06:21:23.306 7fd684b4a720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)}
03/26/2026 06:21:23.306 7fd684b4a720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fd683252490> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)])
03/26/2026 06:21:23.307 7fd684b4a720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/26/2026 06:21:23.307 7fd684b4a720 [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=990524129, session_epoch=1835, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:23.307 7fd684b4a720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Request 1841 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=990524129, session_epoch=1835, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:23.307 7fd684b4a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36944.938721, idle connection 516313.000000, request 304999.943256
03/26/2026 06:21:23.307 7fd684b4a720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36944.463135, idle connection 516313.000000, request 304999.475956
03/26/2026 06:21:23.388 7fd684b4ac20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 174
03/26/2026 06:21:23.388 7fd684b4ac20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)}
03/26/2026 06:21:23.388 7fd684b4ac20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fd683458ac0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)])
03/26/2026 06:21:23.389 7fd684b4ac20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/26/2026 06:21:23.389 7fd684b4ac20 [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=1195686410, session_epoch=1750, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:23.389 7fd684b4ac20 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Request 1758 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1195686410, session_epoch=1750, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:23.389 7fd684b4ac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35801.317383, idle connection 451712.000000, request 304999.935627
03/26/2026 06:21:23.390 7fd684b4ac20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35800.845703, idle connection 451711.000000, request 304999.476433
03/26/2026 06:21:23.416 7fd684b4a680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 44720.445068, idle connection 222308.000000, request 304398.932934
03/26/2026 06:21:23.416 7fd684b4a680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 2224
03/26/2026 06:21:23.416 7fd684b4a680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/26/2026 06:21:23.416 7fd684b4a680 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 2224 (601.6261577606201 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=902623053, topics=[])
03/26/2026 06:21:23.417 7fd684b4a680 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 902623053 with 0 response partitions (1 implied)
03/26/2026 06:21:23.488 7fd684b4ae00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 42101.163574, idle connection 282098.000000, request 304398.841619
03/26/2026 06:21:23.488 7fd684b4ae00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1966
03/26/2026 06:21:23.488 7fd684b4ae00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/26/2026 06:21:23.489 7fd684b4ae00 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 1966 (601.7277240753174 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=40050549, topics=[])
03/26/2026 06:21:23.489 7fd684b4ae00 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 40050549 with 0 response partitions (1 implied)
03/26/2026 06:21:23.497 7fd686b44900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 429
03/26/2026 06:21:23.497 7fd686b44900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)}
03/26/2026 06:21:23.497 7fd686b44900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fd683249760> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)])
03/26/2026 06:21:23.498 7fd686b44900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/26/2026 06:21:23.498 7fd686b44900 [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=1242907814, session_epoch=1773, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:23.498 7fd686b44900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Request 1776 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1242907814, session_epoch=1773, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:23.498 7fd686b44900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35087.906494, idle connection 275086.000000, request 304999.946356
03/26/2026 06:21:23.498 7fd686b44900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35087.478271, idle connection 275085.000000, request 304999.526262
03/26/2026 06:21:23.615 7fd684b4acc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 44
03/26/2026 06:21:23.615 7fd684b4acc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)}
03/26/2026 06:21:23.615 7fd684b4acc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fd683333370> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)])
03/26/2026 06:21:23.615 7fd684b4acc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/26/2026 06:21:23.616 7fd684b4acc0 [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=879405966, session_epoch=1721, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:23.616 7fd684b4acc0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Request 1725 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=879405966, session_epoch=1721, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:23.616 7fd684b4acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35008.890381, idle connection 514080.000000, request 304999.917984
03/26/2026 06:21:23.616 7fd684b4a900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37251.798584, idle connection 277249.000000, request 304396.810770
03/26/2026 06:21:23.617 7fd684b4acc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35008.035156, idle connection 514079.000000, request 304999.076843
03/26/2026 06:21:23.617 7fd684b4a900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1717
03/26/2026 06:21:23.617 7fd684b4a900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/26/2026 06:21:23.618 7fd684b4a900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Response 1717 (604.2187213897705 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=714781556, topics=[])
03/26/2026 06:21:23.618 7fd684b4a900 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 714781556 with 0 response partitions (1 implied)
03/26/2026 06:21:23.695 7fd6835ad720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 563
03/26/2026 06:21:23.695 7fd6835ad720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)}
03/26/2026 06:21:23.695 7fd6835ad720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fd683249850> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)])
03/26/2026 06:21:23.696 7fd6835ad720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/26/2026 06:21:23.696 7fd6835ad720 [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=1466748887, session_epoch=1843, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:23.696 7fd6835ad720 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Request 1845 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1466748887, session_epoch=1843, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:23.696 7fd6835ad720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 34926.992188, idle connection 513789.000000, request 304999.919891
03/26/2026 06:21:23.697 7fd6835ad720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 34926.432373, idle connection 513788.000000, request 304999.362230
03/26/2026 06:21:23.787 7fd6837d9a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 41607.989502, idle connection 281604.000000, request 304397.907019
03/26/2026 06:21:23.788 7fd6837d9a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 3194
03/26/2026 06:21:23.788 7fd6837d9a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/26/2026 06:21:23.788 7fd6837d9a40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.33:9092 <connected> [IPv4 ('10.0.0.33', 9092)]>: Response 3194 (603.0521392822266 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1021309874, topics=[])
03/26/2026 06:21:23.788 7fd6837d9a40 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1021309874 with 0 response partitions (1 implied)
03/26/2026 06:21:23.794 7fd6835ad900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 36361.251953, idle connection 514786.000000, request 304397.692680
03/26/2026 06:21:23.794 7fd6835ad900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1937
03/26/2026 06:21:23.794 7fd6835ad900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
03/26/2026 06:21:23.794 7fd6835ad900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Response 1937 (602.9136180877686 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=616132365, topics=[])
03/26/2026 06:21:23.794 7fd6835ad900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 616132365 with 0 response partitions (1 implied)
03/26/2026 06:21:23.817 7fd684b4af40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 216
03/26/2026 06:21:23.817 7fd684b4af40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)}
03/26/2026 06:21:23.817 7fd684b4af40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fd6832954f0> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)])
03/26/2026 06:21:23.817 7fd684b4af40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
03/26/2026 06:21:23.817 7fd684b4af40 [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=19046972, session_epoch=1757, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:23.817 7fd684b4af40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.242:9092 <connected> [IPv4 ('10.0.0.242', 9092)]>: Request 1760 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=19046972, session_epoch=1757, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:23.817 7fd684b4af40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37258.358154, idle connection 277256.000000, request 304999.947071
03/26/2026 06:21:23.818 7fd684b4af40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 37257.835205, idle connection 277256.000000, request 304999.425411
03/26/2026 06:21:23.836 7fd686b44540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 1187
03/26/2026 06:21:23.836 7fd686b44540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)}
03/26/2026 06:21:23.836 7fd686b44540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fd6832523d0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)])
03/26/2026 06:21:23.837 7fd686b44540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
03/26/2026 06:21:23.837 7fd686b44540 [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=2004697394, session_epoch=1863, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:23.837 7fd686b44540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Request 1864 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2004697394, session_epoch=1863, topics=[], forgotten_topics_data=[])
03/26/2026 06:21:23.837 7fd686b44540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35138.261230, idle connection 275135.000000, request 304999.918699
03/26/2026 06:21:23.838 7fd686b44540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 35137.691650, idle connection 275134.000000, request 304999.361992