12/01/2025 04:39:00.113 7fb0b2015f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 12/01/2025 04:39:00.115 7fb0b2015f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 12/01/2025 04:39:00.115 7fb0b2015f40 [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=1050889726, session_epoch=7621, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:00.116 7fb0b2015f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7635 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1050889726, session_epoch=7621, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:00.116 7fb0b2015f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 212643.789795, idle connection 150154.000000, request 304999.909878 12/01/2025 04:39:00.117 7fb0b2015f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 212642.871094, idle connection 150153.000000, request 304999.004841 12/01/2025 04:39:00.183 7fb0b20b7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 211081.381592, idle connection 149360.000000, request 304398.563385 12/01/2025 04:39:00.183 7fb0b20b7400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7902 12/01/2025 04:39:00.183 7fb0b20b7400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:00.184 7fb0b20b7400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7902 (602.3144721984863 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=924815018, topics=[]) 12/01/2025 04:39:00.184 7fb0b20b7400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 924815018 with 0 response partitions (1 implied) 12/01/2025 04:39:00.345 7fb0b20b7040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 1162 12/01/2025 04:39:00.345 7fb0b20b7040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 12/01/2025 04:39:00.345 7fb0b20b7040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)]) 12/01/2025 04:39:00.346 7fb0b20b7040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/01/2025 04:39:00.346 7fb0b20b7040 [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=762339395, session_epoch=7761, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:00.346 7fb0b20b7040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7783 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=762339395, session_epoch=7761, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:00.346 7fb0b20b7040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210493.667969, idle connection 325149.000000, request 304999.936581 12/01/2025 04:39:00.347 7fb0b20b7040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210493.153564, idle connection 325148.000000, request 304999.429226 12/01/2025 04:39:00.446 7fb0b2015c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210735.341309, idle connection 149213.000000, request 304397.099733 12/01/2025 04:39:00.447 7fb0b2015c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7679 12/01/2025 04:39:00.447 7fb0b2015c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:00.447 7fb0b2015c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 7679 (603.7218570709229 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=28502003, topics=[]) 12/01/2025 04:39:00.447 7fb0b2015c20 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 28502003 with 0 response partitions (1 implied) 12/01/2025 04:39:00.448 7fb0b2015ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209596.768555, idle connection 148001.000000, request 304396.923065 12/01/2025 04:39:00.448 7fb0b2015ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7626 12/01/2025 04:39:00.448 7fb0b2015ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:00.448 7fb0b2015ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7626 (603.8076877593994 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=318032611, topics=[]) 12/01/2025 04:39:00.448 7fb0b2015ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 318032611 with 0 response partitions (1 implied) 12/01/2025 04:39:00.467 7fb0b20b7860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 4447 12/01/2025 04:39:00.467 7fb0b20b7860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 12/01/2025 04:39:00.467 7fb0b20b7860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 12/01/2025 04:39:00.468 7fb0b20b7860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 12/01/2025 04:39:00.468 7fb0b20b7860 [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=1183570130, session_epoch=8332, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:00.468 7fb0b20b7860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 8348 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1183570130, session_epoch=8332, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:00.468 7fb0b20b7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209346.861816, idle connection 146932.000000, request 304999.935150 12/01/2025 04:39:00.469 7fb0b20b7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209346.305176, idle connection 146931.000000, request 304999.389648 12/01/2025 04:39:00.486 7fb0b0328e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209091.380127, idle connection 148137.000000, request 304398.659706 12/01/2025 04:39:00.487 7fb0b0328e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7901 12/01/2025 04:39:00.487 7fb0b0328e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:00.487 7fb0b0328e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 7901 (602.0965576171875 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2090057689, topics=[]) 12/01/2025 04:39:00.488 7fb0b0328e00 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2090057689 with 0 response partitions (1 implied) 12/01/2025 04:39:00.493 7fb0b20b7a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 5416 12/01/2025 04:39:00.493 7fb0b20b7a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 12/01/2025 04:39:00.493 7fb0b20b7a40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 12/01/2025 04:39:00.493 7fb0b20b7a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/01/2025 04:39:00.493 7fb0b20b7a40 [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=1300935199, session_epoch=8284, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:00.493 7fb0b20b7a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 8300 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1300935199, session_epoch=8284, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:00.494 7fb0b20b7a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209583.156494, idle connection 148363.000000, request 304999.921083 12/01/2025 04:39:00.494 7fb0b20b7a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209582.545898, idle connection 148362.000000, request 304999.320030 12/01/2025 04:39:00.518 7fb0b2015d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 261 12/01/2025 04:39:00.518 7fb0b2015d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 12/01/2025 04:39:00.518 7fb0b2015d60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 12/01/2025 04:39:00.519 7fb0b2015d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/01/2025 04:39:00.519 7fb0b2015d60 [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=101110830, session_epoch=7608, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:00.519 7fb0b2015d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7623 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=101110830, session_epoch=7608, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:00.519 7fb0b2015d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 212538.099365, idle connection 387995.000000, request 304999.935627 12/01/2025 04:39:00.520 7fb0b2015d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 212537.627441, idle connection 387995.000000, request 304999.475718 12/01/2025 04:39:00.618 7fb0b20b7b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 3730 12/01/2025 04:39:00.619 7fb0b20b7b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 12/01/2025 04:39:00.619 7fb0b20b7b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 12/01/2025 04:39:00.619 7fb0b20b7b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 12/01/2025 04:39:00.619 7fb0b20b7b80 [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=332819435, session_epoch=8235, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:00.619 7fb0b20b7b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8245 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=332819435, session_epoch=8235, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:00.619 7fb0b20b7b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209532.336670, idle connection 148922.000000, request 304999.940157 12/01/2025 04:39:00.620 7fb0b20b7b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209531.830566, idle connection 148921.000000, request 304999.442101 12/01/2025 04:39:00.718 7fb0b2015f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 212041.346680, idle connection 149552.000000, request 304397.475243 12/01/2025 04:39:00.719 7fb0b2015f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7635 12/01/2025 04:39:00.719 7fb0b2015f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:00.719 7fb0b2015f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7635 (603.1486988067627 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1050889726, topics=[]) 12/01/2025 04:39:00.719 7fb0b2015f40 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1050889726 with 0 response partitions (1 implied) 12/01/2025 04:39:00.786 7fb0b20b7400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 2836 12/01/2025 04:39:00.786 7fb0b20b7400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 12/01/2025 04:39:00.786 7fb0b20b7400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)]) 12/01/2025 04:39:00.786 7fb0b20b7400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/01/2025 04:39:00.786 7fb0b20b7400 [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=924815018, session_epoch=7890, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:00.786 7fb0b20b7400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7903 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=924815018, session_epoch=7890, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:00.787 7fb0b20b7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210477.383789, idle connection 148756.000000, request 304999.942303 12/01/2025 04:39:00.787 7fb0b20b7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210476.821533, idle connection 148756.000000, request 304999.387980 12/01/2025 04:39:00.948 7fb0b20b7040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209891.705322, idle connection 324547.000000, request 304397.974253 12/01/2025 04:39:00.949 7fb0b20b7040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7783 12/01/2025 04:39:00.949 7fb0b20b7040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:00.949 7fb0b20b7040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7783 (602.7050018310547 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=762339395, topics=[]) 12/01/2025 04:39:00.949 7fb0b20b7040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 762339395 with 0 response partitions (1 implied) 12/01/2025 04:39:01.048 7fb0b2015c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 410 12/01/2025 04:39:01.049 7fb0b2015c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 12/01/2025 04:39:01.049 7fb0b2015c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 12/01/2025 04:39:01.049 7fb0b2015c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 12/01/2025 04:39:01.049 7fb0b2015c20 [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=28502003, session_epoch=7665, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:01.049 7fb0b2015c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 7680 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=28502003, session_epoch=7665, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:01.050 7fb0b2015c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210131.962891, idle connection 148609.000000, request 304999.910116 12/01/2025 04:39:01.050 7fb0b2015ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 443 12/01/2025 04:39:01.050 7fb0b2015ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 12/01/2025 04:39:01.050 7fb0b2015ae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)]) 12/01/2025 04:39:01.050 7fb0b2015ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/01/2025 04:39:01.051 7fb0b2015ae0 [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=318032611, session_epoch=7612, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:01.051 7fb0b2015ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7627 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=318032611, session_epoch=7612, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:01.051 7fb0b2015ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208993.315918, idle connection 147398.000000, request 304999.933481 12/01/2025 04:39:01.052 7fb0b2015c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210130.004883, idle connection 148607.000000, request 304997.967482 12/01/2025 04:39:01.052 7fb0b2015ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208992.261230, idle connection 147397.000000, request 304998.892307 12/01/2025 04:39:01.070 7fb0b20b7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208745.145752, idle connection 146330.000000, request 304398.220062 12/01/2025 04:39:01.071 7fb0b20b7860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8348 12/01/2025 04:39:01.071 7fb0b20b7860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:01.071 7fb0b20b7860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 8348 (602.653980255127 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1183570130, topics=[]) 12/01/2025 04:39:01.071 7fb0b20b7860 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1183570130 with 0 response partitions (1 implied) 12/01/2025 04:39:01.089 7fb0b0328e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 1603 12/01/2025 04:39:01.089 7fb0b0328e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 12/01/2025 04:39:01.089 7fb0b0328e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 12/01/2025 04:39:01.090 7fb0b0328e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 12/01/2025 04:39:01.090 7fb0b0328e00 [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=2090057689, session_epoch=7885, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:01.090 7fb0b0328e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 7902 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2090057689, session_epoch=7885, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:01.090 7fb0b0328e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208487.805908, idle connection 147534.000000, request 304999.936342 12/01/2025 04:39:01.091 7fb0b0328e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208487.069092, idle connection 147533.000000, request 304999.208212 12/01/2025 04:39:01.095 7fb0b20b7a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208981.386475, idle connection 147761.000000, request 304398.159981 12/01/2025 04:39:01.096 7fb0b20b7a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8300 12/01/2025 04:39:01.096 7fb0b20b7a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:01.096 7fb0b20b7a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 8300 (602.7491092681885 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1300935199, topics=[]) 12/01/2025 04:39:01.097 7fb0b20b7a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1300935199 with 0 response partitions (1 implied) 12/01/2025 04:39:01.120 7fb0b2015d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 211937.017334, idle connection 387394.000000, request 304398.854494 12/01/2025 04:39:01.121 7fb0b2015d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7623 12/01/2025 04:39:01.121 7fb0b2015d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:01.121 7fb0b2015d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7623 (601.9701957702637 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=101110830, topics=[]) 12/01/2025 04:39:01.121 7fb0b2015d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 101110830 with 0 response partitions (1 implied) 12/01/2025 04:39:01.221 7fb0b20b7b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208930.825439, idle connection 148320.000000, request 304398.421764 12/01/2025 04:39:01.221 7fb0b20b7b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8245 12/01/2025 04:39:01.221 7fb0b20b7b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:01.222 7fb0b20b7b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8245 (602.4744510650635 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=332819435, topics=[]) 12/01/2025 04:39:01.222 7fb0b20b7b80 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 332819435 with 0 response partitions (1 implied) 12/01/2025 04:39:01.324 7fb0b2015f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 542 12/01/2025 04:39:01.324 7fb0b2015f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 12/01/2025 04:39:01.324 7fb0b2015f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 12/01/2025 04:39:01.324 7fb0b2015f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 12/01/2025 04:39:01.324 7fb0b2015f40 [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=1050889726, session_epoch=7622, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:01.325 7fb0b2015f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7636 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1050889726, session_epoch=7622, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:01.325 7fb0b2015f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 211434.753418, idle connection 148945.000000, request 304999.928713 12/01/2025 04:39:01.326 7fb0b2015f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 211433.674805, idle connection 148944.000000, request 304998.862267 12/01/2025 04:39:01.388 7fb0b20b7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209876.192627, idle connection 148155.000000, request 304398.750544 12/01/2025 04:39:01.389 7fb0b20b7400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7903 12/01/2025 04:39:01.389 7fb0b20b7400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:01.389 7fb0b20b7400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7903 (602.1938323974609 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=924815018, topics=[]) 12/01/2025 04:39:01.389 7fb0b20b7400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 924815018 with 0 response partitions (1 implied) 12/01/2025 04:39:01.551 7fb0b20b7040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 1162 12/01/2025 04:39:01.551 7fb0b20b7040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 12/01/2025 04:39:01.552 7fb0b20b7040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)]) 12/01/2025 04:39:01.552 7fb0b20b7040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/01/2025 04:39:01.552 7fb0b20b7040 [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=762339395, session_epoch=7762, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:01.552 7fb0b20b7040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7784 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=762339395, session_epoch=7762, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:01.552 7fb0b20b7040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209287.579346, idle connection 323943.000000, request 304999.941826 12/01/2025 04:39:01.553 7fb0b20b7040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209287.007324, idle connection 323942.000000, request 304999.378204 12/01/2025 04:39:01.653 7fb0b2015c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209528.958252, idle connection 148006.000000, request 304396.912098 12/01/2025 04:39:01.661 7fb0b2015c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7680 12/01/2025 04:39:01.661 7fb0b2015c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:01.661 7fb0b2015c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 7680 (611.6223335266113 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=28502003, topics=[]) 12/01/2025 04:39:01.661 7fb0b2015c20 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 28502003 with 0 response partitions (1 implied) 12/01/2025 04:39:01.662 7fb0b2015ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208382.578857, idle connection 146787.000000, request 304389.203072 12/01/2025 04:39:01.662 7fb0b2015ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7627 12/01/2025 04:39:01.662 7fb0b2015ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:01.662 7fb0b2015ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7627 (611.320972442627 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=318032611, topics=[]) 12/01/2025 04:39:01.662 7fb0b2015ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 318032611 with 0 response partitions (1 implied) 12/01/2025 04:39:01.671 7fb0b20b7860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 4447 12/01/2025 04:39:01.672 7fb0b20b7860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 12/01/2025 04:39:01.672 7fb0b20b7860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 12/01/2025 04:39:01.672 7fb0b20b7860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 12/01/2025 04:39:01.672 7fb0b20b7860 [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=1183570130, session_epoch=8333, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:01.672 7fb0b20b7860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 8349 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1183570130, session_epoch=8333, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:01.673 7fb0b20b7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208142.364014, idle connection 145727.000000, request 304999.931574 12/01/2025 04:39:01.673 7fb0b20b7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208141.897461, idle connection 145727.000000, request 304999.477863 12/01/2025 04:39:01.692 7fb0b0328e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207886.327881, idle connection 146932.000000, request 304398.453236 12/01/2025 04:39:01.692 7fb0b0328e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7902 12/01/2025 04:39:01.692 7fb0b0328e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:01.692 7fb0b0328e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 7902 (602.3528575897217 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2090057689, topics=[]) 12/01/2025 04:39:01.693 7fb0b0328e00 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2090057689 with 0 response partitions (1 implied) 12/01/2025 04:39:01.698 7fb0b20b7a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 5416 12/01/2025 04:39:01.698 7fb0b20b7a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 12/01/2025 04:39:01.699 7fb0b20b7a40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 12/01/2025 04:39:01.699 7fb0b20b7a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/01/2025 04:39:01.699 7fb0b20b7a40 [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=1300935199, session_epoch=8285, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:01.699 7fb0b20b7a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 8301 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1300935199, session_epoch=8285, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:01.699 7fb0b20b7a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208377.511230, idle connection 147157.000000, request 304999.921799 12/01/2025 04:39:01.700 7fb0b20b7a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208376.938477, idle connection 147156.000000, request 304999.360323 12/01/2025 04:39:01.724 7fb0b2015d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 261 12/01/2025 04:39:01.724 7fb0b2015d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 12/01/2025 04:39:01.724 7fb0b2015d60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 12/01/2025 04:39:01.724 7fb0b2015d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/01/2025 04:39:01.724 7fb0b2015d60 [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=101110830, session_epoch=7609, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:01.725 7fb0b2015d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7624 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=101110830, session_epoch=7609, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:01.725 7fb0b2015d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 211332.553711, idle connection 386790.000000, request 304999.914885 12/01/2025 04:39:01.725 7fb0b2015d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 211331.811035, idle connection 386789.000000, request 304999.185085 12/01/2025 04:39:01.824 7fb0b20b7b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 3730 12/01/2025 04:39:01.824 7fb0b20b7b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 12/01/2025 04:39:01.824 7fb0b20b7b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 12/01/2025 04:39:01.824 7fb0b20b7b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 12/01/2025 04:39:01.824 7fb0b20b7b80 [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=332819435, session_epoch=8236, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:01.825 7fb0b20b7b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8246 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=332819435, session_epoch=8236, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:01.825 7fb0b20b7b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208326.634766, idle connection 147716.000000, request 304999.913454 12/01/2025 04:39:01.826 7fb0b20b7b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208325.975098, idle connection 147715.000000, request 304999.271870 12/01/2025 04:39:01.927 7fb0b2015f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210832.859375, idle connection 148343.000000, request 304398.037910 12/01/2025 04:39:01.927 7fb0b2015f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7636 12/01/2025 04:39:01.927 7fb0b2015f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:01.927 7fb0b2015f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7636 (602.6039123535156 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1050889726, topics=[]) 12/01/2025 04:39:01.928 7fb0b2015f40 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1050889726 with 0 response partitions (1 implied) 12/01/2025 04:39:01.990 7fb0b20b7400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 2836 12/01/2025 04:39:01.990 7fb0b20b7400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 12/01/2025 04:39:01.990 7fb0b20b7400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)]) 12/01/2025 04:39:01.991 7fb0b20b7400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/01/2025 04:39:01.991 7fb0b20b7400 [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=924815018, session_epoch=7891, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:01.991 7fb0b20b7400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7904 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=924815018, session_epoch=7891, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:01.991 7fb0b20b7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209273.060547, idle connection 147552.000000, request 304999.943733 12/01/2025 04:39:01.991 7fb0b20b7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209272.562500, idle connection 147552.000000, request 304999.453545 12/01/2025 04:39:02.162 7fb0b20b7040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208677.676025, idle connection 323333.000000, request 304390.030146 12/01/2025 04:39:02.163 7fb0b20b7040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7784 12/01/2025 04:39:02.163 7fb0b20b7040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:02.163 7fb0b20b7040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7784 (610.7306480407715 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=762339395, topics=[]) 12/01/2025 04:39:02.163 7fb0b20b7040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 762339395 with 0 response partitions (1 implied) 12/01/2025 04:39:02.262 7fb0b2015c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 410 12/01/2025 04:39:02.263 7fb0b2015c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 12/01/2025 04:39:02.263 7fb0b2015c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 12/01/2025 04:39:02.263 7fb0b2015c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 12/01/2025 04:39:02.263 7fb0b2015c20 [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=28502003, session_epoch=7666, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:02.263 7fb0b2015c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 7681 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=28502003, session_epoch=7666, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:02.263 7fb0b2015c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208918.260498, idle connection 147396.000000, request 304999.939680 12/01/2025 04:39:02.264 7fb0b2015ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 443 12/01/2025 04:39:02.264 7fb0b2015ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 12/01/2025 04:39:02.264 7fb0b2015ae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)]) 12/01/2025 04:39:02.264 7fb0b2015ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/01/2025 04:39:02.264 7fb0b2015ae0 [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=318032611, session_epoch=7613, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:02.264 7fb0b2015ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7628 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=318032611, session_epoch=7613, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:02.264 7fb0b2015ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207779.859619, idle connection 146184.000000, request 304999.955177 12/01/2025 04:39:02.265 7fb0b2015c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208916.471436, idle connection 147394.000000, request 304998.161554 12/01/2025 04:39:02.266 7fb0b2015ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207778.709717, idle connection 146183.000000, request 304998.811245 12/01/2025 04:39:02.274 7fb0b20b7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207540.994141, idle connection 145126.000000, request 304398.560524 12/01/2025 04:39:02.275 7fb0b20b7860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8349 12/01/2025 04:39:02.275 7fb0b20b7860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:02.275 7fb0b20b7860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 8349 (602.1769046783447 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1183570130, topics=[]) 12/01/2025 04:39:02.275 7fb0b20b7860 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1183570130 with 0 response partitions (1 implied) 12/01/2025 04:39:02.294 7fb0b0328e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 1603 12/01/2025 04:39:02.295 7fb0b0328e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 12/01/2025 04:39:02.295 7fb0b0328e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 12/01/2025 04:39:02.295 7fb0b0328e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 12/01/2025 04:39:02.295 7fb0b0328e00 [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=2090057689, session_epoch=7886, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:02.295 7fb0b0328e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 7903 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2090057689, session_epoch=7886, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:02.296 7fb0b0328e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207282.250244, idle connection 146328.000000, request 304999.893188 12/01/2025 04:39:02.296 7fb0b0328e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207281.635498, idle connection 146327.000000, request 304999.299288 12/01/2025 04:39:02.302 7fb0b20b7a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207775.314941, idle connection 146555.000000, request 304397.666216 12/01/2025 04:39:02.302 7fb0b20b7a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8301 12/01/2025 04:39:02.302 7fb0b20b7a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:02.302 7fb0b20b7a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 8301 (602.8661727905273 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1300935199, topics=[]) 12/01/2025 04:39:02.302 7fb0b20b7a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1300935199 with 0 response partitions (1 implied) 12/01/2025 04:39:02.326 7fb0b2015d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210731.074951, idle connection 386188.000000, request 304398.446798 12/01/2025 04:39:02.327 7fb0b2015d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7624 12/01/2025 04:39:02.327 7fb0b2015d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:02.327 7fb0b2015d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7624 (602.6127338409424 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=101110830, topics=[]) 12/01/2025 04:39:02.328 7fb0b2015d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 101110830 with 0 response partitions (1 implied) 12/01/2025 04:39:02.426 7fb0b20b7b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207725.182617, idle connection 147114.000000, request 304398.471117 12/01/2025 04:39:02.427 7fb0b20b7b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8246 12/01/2025 04:39:02.427 7fb0b20b7b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:02.427 7fb0b20b7b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8246 (602.4191379547119 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=332819435, topics=[]) 12/01/2025 04:39:02.427 7fb0b20b7b80 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 332819435 with 0 response partitions (1 implied) 12/01/2025 04:39:02.529 7fb0b2015f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 542 12/01/2025 04:39:02.529 7fb0b2015f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 12/01/2025 04:39:02.530 7fb0b2015f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 12/01/2025 04:39:02.530 7fb0b2015f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 12/01/2025 04:39:02.530 7fb0b2015f40 [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=1050889726, session_epoch=7623, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:02.530 7fb0b2015f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7637 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1050889726, session_epoch=7623, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:02.530 7fb0b2015f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210229.521240, idle connection 147740.000000, request 304999.940395 12/01/2025 04:39:02.531 7fb0b2015f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210229.012207, idle connection 147739.000000, request 304999.441385 12/01/2025 04:39:02.592 7fb0b20b7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208671.869873, idle connection 146951.000000, request 304398.746252 12/01/2025 04:39:02.593 7fb0b20b7400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7904 12/01/2025 04:39:02.593 7fb0b20b7400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:02.593 7fb0b20b7400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7904 (602.0867824554443 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=924815018, topics=[]) 12/01/2025 04:39:02.593 7fb0b20b7400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 924815018 with 0 response partitions (1 implied) 12/01/2025 04:39:02.765 7fb0b20b7040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 1162 12/01/2025 04:39:02.765 7fb0b20b7040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 12/01/2025 04:39:02.765 7fb0b20b7040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)]) 12/01/2025 04:39:02.765 7fb0b20b7040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/01/2025 04:39:02.765 7fb0b20b7040 [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=762339395, session_epoch=7763, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:02.765 7fb0b20b7040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7785 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=762339395, session_epoch=7763, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:02.766 7fb0b20b7040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208074.107422, idle connection 322729.000000, request 304999.918699 12/01/2025 04:39:02.766 7fb0b20b7040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208073.493408, idle connection 322729.000000, request 304999.316931 12/01/2025 04:39:02.866 7fb0b2015c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208315.254395, idle connection 146793.000000, request 304396.927834 12/01/2025 04:39:02.867 7fb0b2015c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7681 12/01/2025 04:39:02.867 7fb0b2015c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:02.867 7fb0b2015c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 7681 (604.0835380554199 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=28502003, topics=[]) 12/01/2025 04:39:02.868 7fb0b2015c20 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 28502003 with 0 response partitions (1 implied) 12/01/2025 04:39:02.868 7fb0b2015ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207176.234863, idle connection 145581.000000, request 304396.327496 12/01/2025 04:39:02.869 7fb0b2015ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7628 12/01/2025 04:39:02.869 7fb0b2015ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:02.869 7fb0b2015ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7628 (604.3698787689209 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=318032611, topics=[]) 12/01/2025 04:39:02.869 7fb0b2015ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 318032611 with 0 response partitions (1 implied) 12/01/2025 04:39:02.876 7fb0b20b7860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 4447 12/01/2025 04:39:02.876 7fb0b20b7860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 12/01/2025 04:39:02.876 7fb0b20b7860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 12/01/2025 04:39:02.876 7fb0b20b7860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 12/01/2025 04:39:02.876 7fb0b20b7860 [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=1183570130, session_epoch=8334, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:02.877 7fb0b20b7860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 8350 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1183570130, session_epoch=8334, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:02.877 7fb0b20b7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206938.277344, idle connection 144523.000000, request 304999.917984 12/01/2025 04:39:02.877 7fb0b20b7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206937.731445, idle connection 144522.000000, request 304999.385595 12/01/2025 04:39:02.897 7fb0b0328e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206680.972412, idle connection 145727.000000, request 304398.619890 12/01/2025 04:39:02.897 7fb0b0328e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7903 12/01/2025 04:39:02.898 7fb0b0328e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:02.898 7fb0b0328e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 7903 (602.1373271942139 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2090057689, topics=[]) 12/01/2025 04:39:02.898 7fb0b0328e00 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2090057689 with 0 response partitions (1 implied) 12/01/2025 04:39:02.904 7fb0b20b7a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 5416 12/01/2025 04:39:02.904 7fb0b20b7a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 12/01/2025 04:39:02.904 7fb0b20b7a40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 12/01/2025 04:39:02.904 7fb0b20b7a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/01/2025 04:39:02.904 7fb0b20b7a40 [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=1300935199, session_epoch=8286, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:02.904 7fb0b20b7a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 8302 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1300935199, session_epoch=8286, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:02.905 7fb0b20b7a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207172.109863, idle connection 145952.000000, request 304999.918222 12/01/2025 04:39:02.905 7fb0b20b7a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207171.473389, idle connection 145951.000000, request 304999.293566 12/01/2025 04:39:02.930 7fb0b2015d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 261 12/01/2025 04:39:02.930 7fb0b2015d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 12/01/2025 04:39:02.930 7fb0b2015d60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 12/01/2025 04:39:02.930 7fb0b2015d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/01/2025 04:39:02.930 7fb0b2015d60 [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=101110830, session_epoch=7610, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:02.931 7fb0b2015d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7625 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=101110830, session_epoch=7610, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:02.931 7fb0b2015d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210126.374756, idle connection 385584.000000, request 304999.918222 12/01/2025 04:39:02.932 7fb0b2015d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210125.722656, idle connection 385583.000000, request 304999.277353 12/01/2025 04:39:03.030 7fb0b20b7b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 3730 12/01/2025 04:39:03.030 7fb0b20b7b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 12/01/2025 04:39:03.030 7fb0b20b7b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 12/01/2025 04:39:03.030 7fb0b20b7b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 12/01/2025 04:39:03.031 7fb0b20b7b80 [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=332819435, session_epoch=8237, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:03.031 7fb0b20b7b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8247 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=332819435, session_epoch=8237, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:03.031 7fb0b20b7b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207120.435059, idle connection 146510.000000, request 304999.916792 12/01/2025 04:39:03.032 7fb0b20b7b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207119.821533, idle connection 146509.000000, request 304999.314785 12/01/2025 04:39:03.132 7fb0b2015f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209627.462646, idle connection 147138.000000, request 304397.876024 12/01/2025 04:39:03.133 7fb0b2015f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7637 12/01/2025 04:39:03.133 7fb0b2015f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:03.133 7fb0b2015f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7637 (602.9629707336426 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1050889726, topics=[]) 12/01/2025 04:39:03.133 7fb0b2015f40 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1050889726 with 0 response partitions (1 implied) 12/01/2025 04:39:03.195 7fb0b20b7400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 2836 12/01/2025 04:39:03.195 7fb0b20b7400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 12/01/2025 04:39:03.195 7fb0b20b7400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)]) 12/01/2025 04:39:03.195 7fb0b20b7400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/01/2025 04:39:03.195 7fb0b20b7400 [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=924815018, session_epoch=7892, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:03.196 7fb0b20b7400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7905 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=924815018, session_epoch=7892, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:03.196 7fb0b20b7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208068.208984, idle connection 146347.000000, request 304999.944687 12/01/2025 04:39:03.196 7fb0b20b7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208067.704346, idle connection 146347.000000, request 304999.447823 12/01/2025 04:39:03.369 7fb0b20b7040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207471.263428, idle connection 322127.000000, request 304397.081614 12/01/2025 04:39:03.369 7fb0b20b7040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7785 12/01/2025 04:39:03.369 7fb0b20b7040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:03.369 7fb0b20b7040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7785 (603.4977436065674 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=762339395, topics=[]) 12/01/2025 04:39:03.369 7fb0b20b7040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 762339395 with 0 response partitions (1 implied) 12/01/2025 04:39:03.469 7fb0b2015c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 410 12/01/2025 04:39:03.470 7fb0b2015c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 12/01/2025 04:39:03.470 7fb0b2015c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 12/01/2025 04:39:03.470 7fb0b2015c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 12/01/2025 04:39:03.470 7fb0b2015c20 [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=28502003, session_epoch=7667, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:03.470 7fb0b2015c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 7682 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=28502003, session_epoch=7667, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:03.470 7fb0b2015c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207711.229248, idle connection 146189.000000, request 304999.937296 12/01/2025 04:39:03.471 7fb0b2015ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 443 12/01/2025 04:39:03.471 7fb0b2015ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 12/01/2025 04:39:03.471 7fb0b2015ae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)]) 12/01/2025 04:39:03.471 7fb0b2015ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/01/2025 04:39:03.471 7fb0b2015ae0 [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=318032611, session_epoch=7614, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:03.471 7fb0b2015ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7629 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=318032611, session_epoch=7614, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:03.471 7fb0b2015ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206572.892090, idle connection 144977.000000, request 304999.940634 12/01/2025 04:39:03.472 7fb0b2015c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207709.564453, idle connection 146187.000000, request 304998.283863 12/01/2025 04:39:03.472 7fb0b2015ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206571.949707, idle connection 144976.000000, request 304999.006271 12/01/2025 04:39:03.479 7fb0b20b7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206336.080566, idle connection 143921.000000, request 304397.730827 12/01/2025 04:39:03.479 7fb0b20b7860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8350 12/01/2025 04:39:03.479 7fb0b20b7860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:03.480 7fb0b20b7860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 8350 (602.8571128845215 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1183570130, topics=[]) 12/01/2025 04:39:03.480 7fb0b20b7860 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1183570130 with 0 response partitions (1 implied) 12/01/2025 04:39:03.499 7fb0b0328e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 1603 12/01/2025 04:39:03.499 7fb0b0328e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 12/01/2025 04:39:03.500 7fb0b0328e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 12/01/2025 04:39:03.500 7fb0b0328e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 12/01/2025 04:39:03.500 7fb0b0328e00 [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=2090057689, session_epoch=7887, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:03.500 7fb0b0328e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 7904 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2090057689, session_epoch=7887, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:03.500 7fb0b0328e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206077.820068, idle connection 145124.000000, request 304999.930143 12/01/2025 04:39:03.500 7fb0b0328e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206077.340332, idle connection 145123.000000, request 304999.460220 12/01/2025 04:39:03.507 7fb0b20b7a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206570.196777, idle connection 145350.000000, request 304398.012638 12/01/2025 04:39:03.507 7fb0b20b7a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8302 12/01/2025 04:39:03.507 7fb0b20b7a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:03.507 7fb0b20b7a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 8302 (602.705717086792 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1300935199, topics=[]) 12/01/2025 04:39:03.508 7fb0b20b7a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1300935199 with 0 response partitions (1 implied) 12/01/2025 04:39:03.532 7fb0b2015d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209524.863525, idle connection 384982.000000, request 304398.412466 12/01/2025 04:39:03.533 7fb0b2015d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7625 12/01/2025 04:39:03.533 7fb0b2015d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:03.533 7fb0b2015d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7625 (602.2133827209473 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=101110830, topics=[]) 12/01/2025 04:39:03.533 7fb0b2015d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 101110830 with 0 response partitions (1 implied) 12/01/2025 04:39:03.634 7fb0b20b7b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206517.700928, idle connection 145907.000000, request 304397.188425 12/01/2025 04:39:03.634 7fb0b20b7b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8247 12/01/2025 04:39:03.634 7fb0b20b7b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:03.635 7fb0b20b7b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8247 (603.5492420196533 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=332819435, topics=[]) 12/01/2025 04:39:03.635 7fb0b20b7b80 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 332819435 with 0 response partitions (1 implied) 12/01/2025 04:39:03.735 7fb0b2015f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 542 12/01/2025 04:39:03.735 7fb0b2015f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 12/01/2025 04:39:03.735 7fb0b2015f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 12/01/2025 04:39:03.735 7fb0b2015f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 12/01/2025 04:39:03.735 7fb0b2015f40 [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=1050889726, session_epoch=7624, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:03.735 7fb0b2015f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7638 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1050889726, session_epoch=7624, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:03.735 7fb0b2015f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209024.168213, idle connection 146534.000000, request 304999.939203 12/01/2025 04:39:03.736 7fb0b2015f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209023.597900, idle connection 146534.000000, request 304999.380827 12/01/2025 04:39:03.797 7fb0b20b7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207466.895264, idle connection 145746.000000, request 304398.624182 12/01/2025 04:39:03.798 7fb0b20b7400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7905 12/01/2025 04:39:03.798 7fb0b20b7400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:03.798 7fb0b20b7400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7905 (602.191686630249 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=924815018, topics=[]) 12/01/2025 04:39:03.798 7fb0b20b7400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 924815018 with 0 response partitions (1 implied) 12/01/2025 04:39:03.972 7fb0b20b7040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 1162 12/01/2025 04:39:03.973 7fb0b20b7040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 12/01/2025 04:39:03.973 7fb0b20b7040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)]) 12/01/2025 04:39:03.973 7fb0b20b7040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/01/2025 04:39:03.973 7fb0b20b7040 [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=762339395, session_epoch=7764, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:03.973 7fb0b20b7040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7786 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=762339395, session_epoch=7764, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:03.973 7fb0b20b7040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206866.558350, idle connection 321522.000000, request 304999.942064 12/01/2025 04:39:03.974 7fb0b20b7040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206866.086182, idle connection 321521.000000, request 304999.479771 12/01/2025 04:39:04.073 7fb0b2015c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207108.609131, idle connection 145586.000000, request 304397.316933 12/01/2025 04:39:04.074 7fb0b2015c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7682 12/01/2025 04:39:04.074 7fb0b2015c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:04.074 7fb0b2015c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 7682 (603.6052703857422 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=28502003, topics=[]) 12/01/2025 04:39:04.074 7fb0b2015c20 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 28502003 with 0 response partitions (1 implied) 12/01/2025 04:39:04.074 7fb0b2015ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205969.871582, idle connection 144374.000000, request 304396.922350 12/01/2025 04:39:04.075 7fb0b2015ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7629 12/01/2025 04:39:04.075 7fb0b2015ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:04.075 7fb0b2015ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7629 (603.569507598877 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=318032611, topics=[]) 12/01/2025 04:39:04.075 7fb0b2015ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 318032611 with 0 response partitions (1 implied) 12/01/2025 04:39:04.080 7fb0b20b7860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 4447 12/01/2025 04:39:04.080 7fb0b20b7860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 12/01/2025 04:39:04.080 7fb0b20b7860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 12/01/2025 04:39:04.080 7fb0b20b7860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 12/01/2025 04:39:04.080 7fb0b20b7860 [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=1183570130, session_epoch=8335, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:04.081 7fb0b20b7860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 8351 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1183570130, session_epoch=8335, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:04.081 7fb0b20b7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205734.296875, idle connection 143319.000000, request 304999.950647 12/01/2025 04:39:04.081 7fb0b20b7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205733.873535, idle connection 143319.000000, request 304999.533653 12/01/2025 04:39:04.101 7fb0b0328e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205476.746582, idle connection 144523.000000, request 304398.853302 12/01/2025 04:39:04.101 7fb0b0328e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7904 12/01/2025 04:39:04.102 7fb0b0328e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:04.102 7fb0b0328e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 7904 (601.7100811004639 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2090057689, topics=[]) 12/01/2025 04:39:04.102 7fb0b0328e00 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2090057689 with 0 response partitions (1 implied) 12/01/2025 04:39:04.108 7fb0b20b7a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 5416 12/01/2025 04:39:04.108 7fb0b20b7a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 12/01/2025 04:39:04.108 7fb0b20b7a40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 12/01/2025 04:39:04.109 7fb0b20b7a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/01/2025 04:39:04.109 7fb0b20b7a40 [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=1300935199, session_epoch=8287, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:04.109 7fb0b20b7a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 8303 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1300935199, session_epoch=8287, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:04.109 7fb0b20b7a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205967.873047, idle connection 144747.000000, request 304999.948025 12/01/2025 04:39:04.109 7fb0b20b7a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205967.412598, idle connection 144747.000000, request 304999.490976 12/01/2025 04:39:04.134 7fb0b2015d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 261 12/01/2025 04:39:04.134 7fb0b2015d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 12/01/2025 04:39:04.134 7fb0b2015d60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 12/01/2025 04:39:04.134 7fb0b2015d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/01/2025 04:39:04.135 7fb0b2015d60 [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=101110830, session_epoch=7611, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:04.135 7fb0b2015d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7626 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=101110830, session_epoch=7611, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:04.135 7fb0b2015d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208922.206787, idle connection 384379.000000, request 304999.941587 12/01/2025 04:39:04.136 7fb0b2015d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208921.721924, idle connection 384379.000000, request 304999.467373 12/01/2025 04:39:04.236 7fb0b20b7b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 3730 12/01/2025 04:39:04.236 7fb0b20b7b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 12/01/2025 04:39:04.237 7fb0b20b7b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 12/01/2025 04:39:04.237 7fb0b20b7b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 12/01/2025 04:39:04.237 7fb0b20b7b80 [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=332819435, session_epoch=8238, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:04.237 7fb0b20b7b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8248 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=332819435, session_epoch=8238, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:04.237 7fb0b20b7b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205914.358643, idle connection 145304.000000, request 304999.932051 12/01/2025 04:39:04.238 7fb0b20b7b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205913.721191, idle connection 145303.000000, request 304999.308348 12/01/2025 04:39:04.337 7fb0b2015f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208422.824463, idle connection 145933.000000, request 304398.596048 12/01/2025 04:39:04.337 7fb0b2015f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7638 12/01/2025 04:39:04.337 7fb0b2015f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:04.338 7fb0b2015f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7638 (602.1003723144531 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1050889726, topics=[]) 12/01/2025 04:39:04.338 7fb0b2015f40 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1050889726 with 0 response partitions (1 implied) 12/01/2025 04:39:04.399 7fb0b20b7400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 2836 12/01/2025 04:39:04.400 7fb0b20b7400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 12/01/2025 04:39:04.400 7fb0b20b7400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)]) 12/01/2025 04:39:04.400 7fb0b20b7400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/01/2025 04:39:04.400 7fb0b20b7400 [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=924815018, session_epoch=7893, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:04.400 7fb0b20b7400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7906 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=924815018, session_epoch=7893, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:04.400 7fb0b20b7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206863.598633, idle connection 145143.000000, request 304999.916792 12/01/2025 04:39:04.401 7fb0b20b7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206863.125977, idle connection 145142.000000, request 304999.458790 12/01/2025 04:39:04.575 7fb0b20b7040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206264.888672, idle connection 320920.000000, request 304398.265123 12/01/2025 04:39:04.575 7fb0b20b7040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7786 12/01/2025 04:39:04.576 7fb0b20b7040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:04.576 7fb0b20b7040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7786 (602.4773120880127 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=762339395, topics=[]) 12/01/2025 04:39:04.576 7fb0b20b7040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 762339395 with 0 response partitions (1 implied) 12/01/2025 04:39:04.675 7fb0b2015c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 410 12/01/2025 04:39:04.676 7fb0b2015c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 12/01/2025 04:39:04.676 7fb0b2015c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 12/01/2025 04:39:04.676 7fb0b2015c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 12/01/2025 04:39:04.676 7fb0b2015c20 [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=28502003, session_epoch=7668, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:04.676 7fb0b2015c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 7683 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=28502003, session_epoch=7668, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:04.676 7fb0b2015c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206505.235596, idle connection 144983.000000, request 304999.933720 12/01/2025 04:39:04.677 7fb0b2015ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 443 12/01/2025 04:39:04.677 7fb0b2015ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 12/01/2025 04:39:04.677 7fb0b2015ae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)]) 12/01/2025 04:39:04.677 7fb0b2015ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/01/2025 04:39:04.677 7fb0b2015ae0 [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=318032611, session_epoch=7615, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:04.677 7fb0b2015ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7630 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=318032611, session_epoch=7615, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:04.677 7fb0b2015ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205366.855225, idle connection 143771.000000, request 304999.947071 12/01/2025 04:39:04.678 7fb0b2015c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206503.673584, idle connection 144981.000000, request 304998.383760 12/01/2025 04:39:04.678 7fb0b2015ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205366.101074, idle connection 143771.000000, request 304999.202013 12/01/2025 04:39:04.682 7fb0b20b7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205132.596680, idle connection 142717.000000, request 304398.251295 12/01/2025 04:39:04.683 7fb0b20b7860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8351 12/01/2025 04:39:04.683 7fb0b20b7860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:04.683 7fb0b20b7860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 8351 (602.2539138793945 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1183570130, topics=[]) 12/01/2025 04:39:04.683 7fb0b20b7860 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1183570130 with 0 response partitions (1 implied) 12/01/2025 04:39:04.703 7fb0b0328e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 1603 12/01/2025 04:39:04.703 7fb0b0328e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 12/01/2025 04:39:04.703 7fb0b0328e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 12/01/2025 04:39:04.703 7fb0b0328e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 12/01/2025 04:39:04.703 7fb0b0328e00 [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=2090057689, session_epoch=7888, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:04.703 7fb0b0328e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 7905 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2090057689, session_epoch=7888, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:04.704 7fb0b0328e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204874.269531, idle connection 143920.000000, request 304999.943495 12/01/2025 04:39:04.704 7fb0b0328e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204873.819580, idle connection 143920.000000, request 304999.501467 12/01/2025 04:39:04.711 7fb0b20b7a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205365.548096, idle connection 144145.000000, request 304397.616386 12/01/2025 04:39:04.712 7fb0b20b7a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8303 12/01/2025 04:39:04.712 7fb0b20b7a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:04.712 7fb0b20b7a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 8303 (603.0776500701904 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1300935199, topics=[]) 12/01/2025 04:39:04.712 7fb0b20b7a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1300935199 with 0 response partitions (1 implied) 12/01/2025 04:39:04.738 7fb0b2015d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208319.582275, idle connection 383777.000000, request 304397.307634 12/01/2025 04:39:04.738 7fb0b2015d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7626 12/01/2025 04:39:04.738 7fb0b2015d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:04.738 7fb0b2015d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7626 (603.3380031585693 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=101110830, topics=[]) 12/01/2025 04:39:04.739 7fb0b2015d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 101110830 with 0 response partitions (1 implied) 12/01/2025 04:39:04.839 7fb0b20b7b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205312.300781, idle connection 144702.000000, request 304397.878408 12/01/2025 04:39:04.840 7fb0b20b7b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8248 12/01/2025 04:39:04.840 7fb0b20b7b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:04.840 7fb0b20b7b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8248 (602.7214527130127 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=332819435, topics=[]) 12/01/2025 04:39:04.840 7fb0b20b7b80 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 332819435 with 0 response partitions (1 implied) 12/01/2025 04:39:04.939 7fb0b2015f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 542 12/01/2025 04:39:04.939 7fb0b2015f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 12/01/2025 04:39:04.939 7fb0b2015f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 12/01/2025 04:39:04.939 7fb0b2015f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 12/01/2025 04:39:04.939 7fb0b2015f40 [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=1050889726, session_epoch=7625, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:04.939 7fb0b2015f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7639 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1050889726, session_epoch=7625, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:04.939 7fb0b2015f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207820.181152, idle connection 145330.000000, request 304999.936104 12/01/2025 04:39:04.940 7fb0b2015f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207819.722168, idle connection 145330.000000, request 304999.490499 12/01/2025 04:39:05.001 7fb0b20b7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206262.527832, idle connection 144542.000000, request 304398.849010 12/01/2025 04:39:05.002 7fb0b20b7400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7906 12/01/2025 04:39:05.002 7fb0b20b7400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:05.002 7fb0b20b7400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7906 (601.7458438873291 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=924815018, topics=[]) 12/01/2025 04:39:05.002 7fb0b20b7400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 924815018 with 0 response partitions (1 implied) 12/01/2025 04:39:05.178 7fb0b20b7040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 1162 12/01/2025 04:39:05.178 7fb0b20b7040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 12/01/2025 04:39:05.178 7fb0b20b7040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)]) 12/01/2025 04:39:05.178 7fb0b20b7040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/01/2025 04:39:05.178 7fb0b20b7040 [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=762339395, session_epoch=7765, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:05.178 7fb0b20b7040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7787 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=762339395, session_epoch=7765, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:05.178 7fb0b20b7040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205661.349121, idle connection 320317.000000, request 304999.941349 12/01/2025 04:39:05.179 7fb0b20b7040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205660.846436, idle connection 320316.000000, request 304999.448776 12/01/2025 04:39:05.279 7fb0b2015c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205902.662354, idle connection 144380.000000, request 304397.356272 12/01/2025 04:39:05.279 7fb0b2015c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7683 12/01/2025 04:39:05.279 7fb0b2015c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:05.280 7fb0b2015c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 7683 (603.3337116241455 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=28502003, topics=[]) 12/01/2025 04:39:05.280 7fb0b2015c20 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 28502003 with 0 response partitions (1 implied) 12/01/2025 04:39:05.280 7fb0b2015ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204764.212891, idle connection 143169.000000, request 304397.310972 12/01/2025 04:39:05.280 7fb0b2015ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7630 12/01/2025 04:39:05.280 7fb0b2015ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:05.281 7fb0b2015ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7630 (603.1215190887451 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=318032611, topics=[]) 12/01/2025 04:39:05.281 7fb0b2015ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 318032611 with 0 response partitions (1 implied) 12/01/2025 04:39:05.284 7fb0b20b7860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 4447 12/01/2025 04:39:05.284 7fb0b20b7860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 12/01/2025 04:39:05.284 7fb0b20b7860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 12/01/2025 04:39:05.284 7fb0b20b7860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 12/01/2025 04:39:05.284 7fb0b20b7860 [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=1183570130, session_epoch=8336, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:05.284 7fb0b20b7860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 8352 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1183570130, session_epoch=8336, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:05.284 7fb0b20b7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204530.675293, idle connection 142115.000000, request 304999.950171 12/01/2025 04:39:05.285 7fb0b20b7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204530.197510, idle connection 142115.000000, request 304999.476194 12/01/2025 04:39:05.305 7fb0b0328e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204273.188965, idle connection 143319.000000, request 304398.859978 12/01/2025 04:39:05.305 7fb0b0328e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7905 12/01/2025 04:39:05.305 7fb0b0328e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:05.305 7fb0b0328e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 7905 (601.7653942108154 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2090057689, topics=[]) 12/01/2025 04:39:05.306 7fb0b0328e00 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2090057689 with 0 response partitions (1 implied) 12/01/2025 04:39:05.313 7fb0b20b7a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 5416 12/01/2025 04:39:05.313 7fb0b20b7a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 12/01/2025 04:39:05.313 7fb0b20b7a40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 12/01/2025 04:39:05.313 7fb0b20b7a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/01/2025 04:39:05.313 7fb0b20b7a40 [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=1300935199, session_epoch=8288, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:05.314 7fb0b20b7a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 8304 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1300935199, session_epoch=8288, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:05.314 7fb0b20b7a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204763.035400, idle connection 143543.000000, request 304999.946833 12/01/2025 04:39:05.314 7fb0b20b7a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204762.537598, idle connection 143542.000000, request 304999.457359 12/01/2025 04:39:05.339 7fb0b2015d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 261 12/01/2025 04:39:05.340 7fb0b2015d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 12/01/2025 04:39:05.340 7fb0b2015d60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 12/01/2025 04:39:05.340 7fb0b2015d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/01/2025 04:39:05.340 7fb0b2015d60 [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=101110830, session_epoch=7612, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:05.340 7fb0b2015d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7627 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=101110830, session_epoch=7612, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:05.340 7fb0b2015d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207716.998047, idle connection 383174.000000, request 304999.935150 12/01/2025 04:39:05.341 7fb0b2015d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207716.392578, idle connection 383174.000000, request 304999.338150 12/01/2025 04:39:05.441 7fb0b20b7b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 3730 12/01/2025 04:39:05.441 7fb0b20b7b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 12/01/2025 04:39:05.441 7fb0b20b7b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 12/01/2025 04:39:05.442 7fb0b20b7b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 12/01/2025 04:39:05.442 7fb0b20b7b80 [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=332819435, session_epoch=8239, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:05.442 7fb0b20b7b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 8249 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=332819435, session_epoch=8239, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:05.442 7fb0b20b7b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204709.535400, idle connection 144099.000000, request 304999.938488 12/01/2025 04:39:05.443 7fb0b20b7b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204708.901855, idle connection 144098.000000, request 304999.315977 12/01/2025 04:39:05.541 7fb0b2015f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207218.373291, idle connection 144729.000000, request 304398.130417 12/01/2025 04:39:05.542 7fb0b2015f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7639 12/01/2025 04:39:05.542 7fb0b2015f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:05.542 7fb0b2015f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7639 (602.7147769927979 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1050889726, topics=[]) 12/01/2025 04:39:05.542 7fb0b2015f40 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1050889726 with 0 response partitions (1 implied) 12/01/2025 04:39:05.605 7fb0b20b7400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 2836 12/01/2025 04:39:05.605 7fb0b20b7400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 12/01/2025 04:39:05.606 7fb0b20b7400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)]) 12/01/2025 04:39:05.606 7fb0b20b7400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/01/2025 04:39:05.606 7fb0b20b7400 [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=924815018, session_epoch=7894, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:05.606 7fb0b20b7400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7907 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=924815018, session_epoch=7894, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:05.606 7fb0b20b7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205657.928955, idle connection 143937.000000, request 304999.943495 12/01/2025 04:39:05.607 7fb0b20b7400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205657.335938, idle connection 143936.000000, request 304999.360085 12/01/2025 04:39:05.781 7fb0b20b7040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205059.316650, idle connection 319715.000000, request 304397.866488 12/01/2025 04:39:05.781 7fb0b20b7040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7787 12/01/2025 04:39:05.781 7fb0b20b7040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:05.782 7fb0b20b7040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7787 (603.1014919281006 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=762339395, topics=[]) 12/01/2025 04:39:05.782 7fb0b20b7040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 762339395 with 0 response partitions (1 implied) 12/01/2025 04:39:05.880 7fb0b2015c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 410 12/01/2025 04:39:05.881 7fb0b2015c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 12/01/2025 04:39:05.881 7fb0b2015c20 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 12/01/2025 04:39:05.881 7fb0b2015c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 12/01/2025 04:39:05.881 7fb0b2015c20 [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=28502003, session_epoch=7669, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:05.881 7fb0b2015c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 7684 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=28502003, session_epoch=7669, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:05.881 7fb0b2015c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205300.269287, idle connection 143778.000000, request 304999.941111 12/01/2025 04:39:05.882 7fb0b2015c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205299.689209, idle connection 143777.000000, request 304999.371767 12/01/2025 04:39:05.882 7fb0b2015ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 443 12/01/2025 04:39:05.882 7fb0b2015ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 12/01/2025 04:39:05.882 7fb0b2015ae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)]) 12/01/2025 04:39:05.882 7fb0b2015ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 12/01/2025 04:39:05.882 7fb0b2015ae0 [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=318032611, session_epoch=7616, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:05.883 7fb0b2015ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7631 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=318032611, session_epoch=7616, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:05.883 7fb0b2015ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204161.659668, idle connection 142566.000000, request 304999.957323 12/01/2025 04:39:05.883 7fb0b2015ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204161.171143, idle connection 142566.000000, request 304999.471664 12/01/2025 04:39:05.886 7fb0b20b7860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203929.015625, idle connection 141514.000000, request 304398.295403 12/01/2025 04:39:05.886 7fb0b20b7860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8352 12/01/2025 04:39:05.886 7fb0b20b7860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:05.886 7fb0b20b7860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 8352 (602.0946502685547 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1183570130, topics=[]) 12/01/2025 04:39:05.887 7fb0b20b7860 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1183570130 with 0 response partitions (1 implied) 12/01/2025 04:39:05.906 7fb0b0328e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 1603 12/01/2025 04:39:05.907 7fb0b0328e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 12/01/2025 04:39:05.907 7fb0b0328e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 12/01/2025 04:39:05.907 7fb0b0328e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 12/01/2025 04:39:05.907 7fb0b0328e00 [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=2090057689, session_epoch=7889, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:05.908 7fb0b0328e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 7906 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2090057689, session_epoch=7889, topics=[], forgotten_topics_data=[]) 12/01/2025 04:39:05.908 7fb0b0328e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203670.057129, idle connection 142716.000000, request 304999.915361 12/01/2025 04:39:05.909 7fb0b0328e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203669.121094, idle connection 142715.000000, request 304998.990059 12/01/2025 04:39:05.916 7fb0b20b7a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204161.160645, idle connection 142941.000000, request 304398.072243 12/01/2025 04:39:05.916 7fb0b20b7a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8304 12/01/2025 04:39:05.916 7fb0b20b7a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:05.917 7fb0b20b7a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 8304 (602.9157638549805 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1300935199, topics=[]) 12/01/2025 04:39:05.917 7fb0b20b7a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1300935199 with 0 response partitions (1 implied) 12/01/2025 04:39:05.943 7fb0b2015d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207114.743652, idle connection 382572.000000, request 304397.680998 12/01/2025 04:39:05.943 7fb0b2015d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7627 12/01/2025 04:39:05.943 7fb0b2015d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:05.943 7fb0b2015d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7627 (603.1644344329834 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=101110830, topics=[]) 12/01/2025 04:39:05.944 7fb0b2015d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 101110830 with 0 response partitions (1 implied) 12/01/2025 04:39:06.044 7fb0b20b7b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204107.247070, idle connection 143496.000000, request 304397.650480 12/01/2025 04:39:06.045 7fb0b20b7b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8249 12/01/2025 04:39:06.045 7fb0b20b7b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 12/01/2025 04:39:06.045 7fb0b20b7b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 8249 (602.9477119445801 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=332819435, topics=[]) 12/01/2025 04:39:06.045 7fb0b20b7b80 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 332819435 with 0 response partitions (1 implied)