06/15/2026 04:04:59.611 7fb42f4f1900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62298.141602, idle connection 721.000000, request 304999.589205 06/15/2026 04:04:59.725 7fb42f4f17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62592.972900, idle connection 1211.000000, request 304398.957253 06/15/2026 04:04:59.726 7fb42f4f17c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6512 06/15/2026 04:04:59.726 7fb42f4f17c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:04:59.726 7fb42f4f17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 6512 (601.5706062316895 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1679018624, topics=[]) 06/15/2026 04:04:59.726 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1679018624 with 0 response partitions (1 implied) 06/15/2026 04:04:59.738 7fb42e183ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59893.275391, idle connection 299891.000000, request 304398.946047 06/15/2026 04:04:59.738 7fb42e183ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9938 06/15/2026 04:04:59.738 7fb42e183ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:04:59.738 7fb42e183ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 9938 (601.5362739562988 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=864390279, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=54988, last_stable_offset=54988, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xd6\xcb\x00\x00\x01\x04\x00\x00\x00\x00\x02\x89T%z\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 06/15/2026 04:04:59.739 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 864390279 with 1 response partitions (0 implied) 06/15/2026 04:04:59.739 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 54987 06/15/2026 04:04:59.739 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 54987 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 06/15/2026 04:04:59.739 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 54988 (leader epoch 0) 06/15/2026 04:04:59.840 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 54988 06/15/2026 04:04:59.840 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 06/15/2026 04:04:59.840 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 06/15/2026 04:04:59.840 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:04:59.841 7fb42e183ea0 [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=864390279, session_epoch=9930, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=54988, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/15/2026 04:04:59.841 7fb42e183ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 9939 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=864390279, session_epoch=9930, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=54988, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/15/2026 04:04:59.841 7fb42e183ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59790.393066, idle connection 299788.000000, request 304999.946356 06/15/2026 04:04:59.841 7fb42e183ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59789.982422, idle connection 299788.000000, request 304999.544859 06/15/2026 04:04:59.973 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 167 06/15/2026 04:04:59.973 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 06/15/2026 04:04:59.973 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 06/15/2026 04:04:59.973 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:04:59.974 7fb42f4f1040 [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=1285042058, session_epoch=6478, topics=[], forgotten_topics_data=[]) 06/15/2026 04:04:59.974 7fb42f4f1040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6502 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1285042058, session_epoch=6478, topics=[], forgotten_topics_data=[]) 06/15/2026 04:04:59.974 7fb42f4f1040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60360.503906, idle connection 115074.000000, request 304999.937057 06/15/2026 04:04:59.974 7fb42f4f1040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60360.077881, idle connection 115074.000000, request 304999.519587 06/15/2026 04:05:00.007 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3850 06/15/2026 04:05:00.007 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 06/15/2026 04:05:00.007 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 06/15/2026 04:05:00.008 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:05:00.008 7fb4314e7ae0 [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=2075216190, session_epoch=7062, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:00.008 7fb4314e7ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7074 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2075216190, session_epoch=7062, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:00.008 7fb4314e7ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 65664.094727, idle connection 3811.000000, request 304999.946356 06/15/2026 04:05:00.008 7fb4314e7ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 65663.653320, idle connection 3811.000000, request 304999.514103 06/15/2026 04:05:00.028 7fb42ded1f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 65902.194336, idle connection 5227.000000, request 304399.070978 06/15/2026 04:05:00.028 7fb42ded1f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7147 06/15/2026 04:05:00.029 7fb42ded1f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:00.029 7fb42ded1f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7147 (601.4101505279541 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=241006407, topics=[]) 06/15/2026 04:05:00.029 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 241006407 with 0 response partitions (1 implied) 06/15/2026 04:05:00.076 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 4357 06/15/2026 04:05:00.077 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 06/15/2026 04:05:00.077 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 06/15/2026 04:05:00.077 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/15/2026 04:05:00.077 7fb42f4f1b80 [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=559822579, session_epoch=6911, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:00.077 7fb42f4f1b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6926 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=559822579, session_epoch=6911, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:00.077 7fb42f4f1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 64946.746094, idle connection 303743.000000, request 304999.951363 06/15/2026 04:05:00.078 7fb42f4f1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 64946.375488, idle connection 303743.000000, request 304999.587536 06/15/2026 04:05:00.081 7fb43147de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 55719.256836, idle connection 336629.000000, request 304399.277925 06/15/2026 04:05:00.081 7fb43147de00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6454 06/15/2026 04:05:00.081 7fb43147de00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:00.081 7fb43147de00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6454 (601.0799407958984 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1410002452, topics=[]) 06/15/2026 04:05:00.081 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1410002452 with 0 response partitions (1 implied) 06/15/2026 04:05:00.083 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4380 06/15/2026 04:05:00.083 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 06/15/2026 04:05:00.083 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 06/15/2026 04:05:00.083 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:00.083 7fb42f4f1cc0 [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=2018373990, session_epoch=6931, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:00.083 7fb42f4f1cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 6953 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2018373990, session_epoch=6931, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:00.083 7fb42f4f1cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 65270.875244, idle connection 4366.000000, request 304999.963760 06/15/2026 04:05:00.084 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 564 06/15/2026 04:05:00.084 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 06/15/2026 04:05:00.084 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 06/15/2026 04:05:00.084 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:05:00.084 7fb42f4f1360 [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=1864963515, session_epoch=6589, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:00.084 7fb42f4f1360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6604 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1864963515, session_epoch=6589, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:00.084 7fb42f4f1360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 65049.040527, idle connection 3780.000000, request 304999.965191 06/15/2026 04:05:00.084 7fb42f4f1cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 65269.958496, idle connection 4365.000000, request 304999.048471 06/15/2026 04:05:00.085 7fb42f4f1360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 65048.501221, idle connection 3779.000000, request 304999.428749 06/15/2026 04:05:00.183 7fb42f4f15e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 65566.737305, idle connection 3784.000000, request 304399.120331 06/15/2026 04:05:00.183 7fb42f4f15e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6620 06/15/2026 04:05:00.183 7fb42f4f15e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:00.183 7fb42f4f15e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 6620 (601.3851165771484 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1278530490, topics=[]) 06/15/2026 04:05:00.184 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1278530490 with 0 response partitions (1 implied) 06/15/2026 04:05:00.212 7fb42f4f1900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61696.365234, idle connection 119.000000, request 304397.804260 06/15/2026 04:05:00.213 7fb42f4f1900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6498 06/15/2026 04:05:00.213 7fb42f4f1900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:00.213 7fb42f4f1900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 6498 (602.7827262878418 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1464583258, topics=[]) 06/15/2026 04:05:00.213 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1464583258 with 0 response partitions (1 implied) 06/15/2026 04:05:00.327 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 289 06/15/2026 04:05:00.327 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 06/15/2026 04:05:00.327 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 06/15/2026 04:05:00.327 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:00.327 7fb42f4f17c0 [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=1679018624, session_epoch=6492, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:00.327 7fb42f4f17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 6513 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1679018624, session_epoch=6492, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:00.327 7fb42f4f17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61991.025635, idle connection 609.000000, request 304999.950647 06/15/2026 04:05:00.328 7fb42f4f17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61990.644043, idle connection 608.000000, request 304999.576330 06/15/2026 04:05:00.442 7fb42e183ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59189.513184, idle connection 299187.000000, request 304399.068117 06/15/2026 04:05:00.442 7fb42e183ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9939 06/15/2026 04:05:00.442 7fb42e183ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:00.442 7fb42e183ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 9939 (601.4819145202637 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=864390279, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=54989, last_stable_offset=54989, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xd6\xcc\x00\x00\x01\x04\x00\x00\x00\x00\x02\xda\x001\x89\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 06/15/2026 04:05:00.443 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 864390279 with 1 response partitions (0 implied) 06/15/2026 04:05:00.443 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 54988 06/15/2026 04:05:00.443 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 54988 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 06/15/2026 04:05:00.443 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 54989 (leader epoch 0) 06/15/2026 04:05:00.544 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 54989 06/15/2026 04:05:00.544 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 06/15/2026 04:05:00.544 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 06/15/2026 04:05:00.544 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:00.544 7fb42e183ea0 [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=864390279, session_epoch=9931, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=54989, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/15/2026 04:05:00.544 7fb42e183ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 9940 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=864390279, session_epoch=9931, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=54989, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/15/2026 04:05:00.544 7fb42e183ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59087.021240, idle connection 299085.000000, request 304999.950171 06/15/2026 04:05:00.545 7fb42e183ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59086.640869, idle connection 299085.000000, request 304999.577522 06/15/2026 04:05:00.575 7fb42f4f1040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59759.203125, idle connection 114473.000000, request 304398.636580 06/15/2026 04:05:00.575 7fb42f4f1040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6502 06/15/2026 04:05:00.576 7fb42f4f1040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:00.576 7fb42f4f1040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6502 (601.8917560577393 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1285042058, topics=[]) 06/15/2026 04:05:00.576 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1285042058 with 0 response partitions (1 implied) 06/15/2026 04:05:00.609 7fb4314e7ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 65063.108887, idle connection 3210.000000, request 304398.960829 06/15/2026 04:05:00.609 7fb4314e7ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7074 06/15/2026 04:05:00.610 7fb4314e7ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:00.610 7fb4314e7ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7074 (601.7990112304688 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2075216190, topics=[]) 06/15/2026 04:05:00.610 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 2075216190 with 0 response partitions (1 implied) 06/15/2026 04:05:00.629 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 4907 06/15/2026 04:05:00.629 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 06/15/2026 04:05:00.630 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 06/15/2026 04:05:00.630 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:05:00.630 7fb42ded1f40 [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=241006407, session_epoch=7130, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:00.630 7fb42ded1f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7148 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=241006407, session_epoch=7130, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:00.630 7fb42ded1f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 65300.180176, idle connection 4625.000000, request 304999.931574 06/15/2026 04:05:00.631 7fb42ded1f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 65299.642334, idle connection 4625.000000, request 304999.402046 06/15/2026 04:05:00.678 7fb42f4f1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 64345.886475, idle connection 303142.000000, request 304399.090528 06/15/2026 04:05:00.678 7fb42f4f1b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6926 06/15/2026 04:05:00.679 7fb42f4f1b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:00.679 7fb42f4f1b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6926 (601.4797687530518 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=559822579, topics=[]) 06/15/2026 04:05:00.679 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 559822579 with 0 response partitions (1 implied) 06/15/2026 04:05:00.681 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 06/15/2026 04:05:00.682 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 06/15/2026 04:05:00.682 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 06/15/2026 04:05:00.682 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:05:00.682 7fb43147de00 [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=1410002452, session_epoch=6428, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:00.682 7fb43147de00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6455 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1410002452, session_epoch=6428, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:00.682 7fb43147de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 55117.839600, idle connection 336028.000000, request 304999.951363 06/15/2026 04:05:00.682 7fb43147de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 55117.453125, idle connection 336027.000000, request 304999.570370 06/15/2026 04:05:00.685 7fb42f4f1cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 64669.218262, idle connection 3765.000000, request 304398.302078 06/15/2026 04:05:00.685 7fb42f4f1cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6953 06/15/2026 04:05:00.686 7fb42f4f1cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:00.686 7fb42f4f1cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 6953 (602.1583080291748 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2018373990, topics=[]) 06/15/2026 04:05:00.686 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2018373990 with 0 response partitions (1 implied) 06/15/2026 04:05:00.686 7fb42f4f1360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 64447.169189, idle connection 3178.000000, request 304398.094654 06/15/2026 04:05:00.686 7fb42f4f1360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6604 06/15/2026 04:05:00.686 7fb42f4f1360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:00.686 7fb42f4f1360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6604 (602.3592948913574 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1864963515, topics=[]) 06/15/2026 04:05:00.687 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1864963515 with 0 response partitions (1 implied) 06/15/2026 04:05:00.784 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 716 06/15/2026 04:05:00.785 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 06/15/2026 04:05:00.785 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)]) 06/15/2026 04:05:00.785 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:00.785 7fb42f4f15e0 [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=1278530490, session_epoch=6602, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:00.785 7fb42f4f15e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 6621 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1278530490, session_epoch=6602, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:00.785 7fb42f4f15e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 64964.370361, idle connection 3181.000000, request 304999.930620 06/15/2026 04:05:00.786 7fb42f4f15e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 64963.830566, idle connection 3181.000000, request 304999.403000 06/15/2026 04:05:00.815 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 360 06/15/2026 04:05:00.815 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 06/15/2026 04:05:00.815 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 06/15/2026 04:05:00.815 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:00.816 7fb42f4f1900 [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=1464583258, session_epoch=6480, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:00.816 7fb42f4f1900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 6499 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1464583258, session_epoch=6480, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:00.816 7fb42f4f1900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61092.822998, idle connection 0.000000, request 304999.929667 06/15/2026 04:05:00.817 7fb42f4f1900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61092.214355, idle connection 301090.000000, request 304999.329090 06/15/2026 04:05:00.928 7fb42f4f17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61390.070312, idle connection 8.000000, request 304398.988724 06/15/2026 04:05:00.929 7fb42f4f17c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6513 06/15/2026 04:05:00.929 7fb42f4f17c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:00.929 7fb42f4f17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 6513 (601.722002029419 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1679018624, topics=[]) 06/15/2026 04:05:00.929 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1679018624 with 0 response partitions (1 implied) 06/15/2026 04:05:01.145 7fb42e183ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 58486.103271, idle connection 298484.000000, request 304399.028540 06/15/2026 04:05:01.146 7fb42e183ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9940 06/15/2026 04:05:01.146 7fb42e183ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:01.146 7fb42e183ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 9940 (601.6154289245605 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=864390279, topics=[]) 06/15/2026 04:05:01.146 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 864390279 with 0 response partitions (1 implied) 06/15/2026 04:05:01.176 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 167 06/15/2026 04:05:01.177 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 06/15/2026 04:05:01.177 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 06/15/2026 04:05:01.177 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:05:01.177 7fb42f4f1040 [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=1285042058, session_epoch=6479, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:01.177 7fb42f4f1040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6503 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1285042058, session_epoch=6479, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:01.178 7fb42f4f1040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59156.795166, idle connection 113871.000000, request 304999.926329 06/15/2026 04:05:01.178 7fb42f4f1040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59156.315674, idle connection 113870.000000, request 304999.460220 06/15/2026 04:05:01.211 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3850 06/15/2026 04:05:01.211 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 06/15/2026 04:05:01.211 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 06/15/2026 04:05:01.212 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:05:01.212 7fb4314e7ae0 [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=2075216190, session_epoch=7063, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:01.212 7fb4314e7ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7075 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2075216190, session_epoch=7063, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:01.212 7fb4314e7ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 64460.161377, idle connection 2607.000000, request 304999.948740 06/15/2026 04:05:01.212 7fb4314e7ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 64459.700684, idle connection 2607.000000, request 304999.495745 06/15/2026 04:05:01.231 7fb42ded1f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 64698.879639, idle connection 4024.000000, request 304398.628712 06/15/2026 04:05:01.232 7fb42ded1f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7148 06/15/2026 04:05:01.232 7fb42ded1f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:01.232 7fb42ded1f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7148 (602.0164489746094 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=241006407, topics=[]) 06/15/2026 04:05:01.232 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 241006407 with 0 response partitions (1 implied) 06/15/2026 04:05:01.280 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 4357 06/15/2026 04:05:01.280 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 06/15/2026 04:05:01.280 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 06/15/2026 04:05:01.280 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/15/2026 04:05:01.280 7fb42f4f1b80 [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=559822579, session_epoch=6912, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:01.280 7fb42f4f1b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6927 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=559822579, session_epoch=6912, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:01.281 7fb42f4f1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63743.419189, idle connection 302540.000000, request 304999.945402 06/15/2026 04:05:01.281 7fb42f4f1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63743.009277, idle connection 302539.000000, request 304999.545813 06/15/2026 04:05:01.283 7fb43147de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 54516.834473, idle connection 335427.000000, request 304398.950577 06/15/2026 04:05:01.283 7fb43147de00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6455 06/15/2026 04:05:01.283 7fb43147de00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:01.283 7fb43147de00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6455 (601.398229598999 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1410002452, topics=[]) 06/15/2026 04:05:01.284 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1410002452 with 0 response partitions (1 implied) 06/15/2026 04:05:01.287 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4380 06/15/2026 04:05:01.287 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 06/15/2026 04:05:01.287 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 06/15/2026 04:05:01.287 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:01.287 7fb42f4f1cc0 [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=2018373990, session_epoch=6932, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:01.287 7fb42f4f1cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 6954 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2018373990, session_epoch=6932, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:01.287 7fb42f4f1cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 64066.899902, idle connection 3162.000000, request 304999.957085 06/15/2026 04:05:01.288 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 564 06/15/2026 04:05:01.288 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 06/15/2026 04:05:01.288 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 06/15/2026 04:05:01.288 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:05:01.288 7fb42f4f1360 [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=1864963515, session_epoch=6590, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:01.288 7fb42f4f1360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6605 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1864963515, session_epoch=6590, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:01.288 7fb42f4f1360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63844.975098, idle connection 2576.000000, request 304999.962330 06/15/2026 04:05:01.288 7fb42f4f1cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 64065.860352, idle connection 3161.000000, request 304998.921156 06/15/2026 04:05:01.289 7fb42f4f1360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63844.379395, idle connection 2575.000000, request 304999.369860 06/15/2026 04:05:01.387 7fb42f4f15e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 64363.089111, idle connection 2580.000000, request 304398.655176 06/15/2026 04:05:01.387 7fb42f4f15e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6621 06/15/2026 04:05:01.387 7fb42f4f15e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:01.387 7fb42f4f15e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 6621 (601.8800735473633 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1278530490, topics=[]) 06/15/2026 04:05:01.387 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1278530490 with 0 response partitions (1 implied) 06/15/2026 04:05:01.417 7fb42f4f1900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60491.520996, idle connection 300489.000000, request 304398.631096 06/15/2026 04:05:01.418 7fb42f4f1900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6499 06/15/2026 04:05:01.418 7fb42f4f1900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:01.418 7fb42f4f1900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 6499 (601.8855571746826 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1464583258, topics=[]) 06/15/2026 04:05:01.418 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1464583258 with 0 response partitions (1 implied) 06/15/2026 04:05:01.532 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 289 06/15/2026 04:05:01.532 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 06/15/2026 04:05:01.532 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 06/15/2026 04:05:01.533 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:01.533 7fb42f4f17c0 [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=1679018624, session_epoch=6493, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:01.533 7fb42f4f17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 6514 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1679018624, session_epoch=6493, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:01.533 7fb42f4f17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60785.350586, idle connection 0.000000, request 304999.944448 06/15/2026 04:05:01.533 7fb42f4f17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60784.906494, idle connection 300783.000000, request 304999.505997 06/15/2026 04:05:01.746 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 54989 06/15/2026 04:05:01.747 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 06/15/2026 04:05:01.747 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 06/15/2026 04:05:01.747 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:01.747 7fb42e183ea0 [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=864390279, session_epoch=9932, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:01.747 7fb42e183ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 9941 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=864390279, session_epoch=9932, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:01.747 7fb42e183ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 57883.861328, idle connection 297882.000000, request 304999.933243 06/15/2026 04:05:01.748 7fb42e183ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 57883.329102, idle connection 297881.000000, request 304999.410152 06/15/2026 04:05:01.853 7fb42f4f1040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 58481.172363, idle connection 113195.000000, request 304324.304819 06/15/2026 04:05:01.854 7fb4314e7ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63818.532471, idle connection 1966.000000, request 304358.323812 06/15/2026 04:05:01.854 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 4907 06/15/2026 04:05:01.854 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 06/15/2026 04:05:01.854 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 06/15/2026 04:05:01.854 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:05:01.854 7fb42ded1f40 [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=241006407, session_epoch=7131, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:01.854 7fb42ded1f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7149 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=241006407, session_epoch=7131, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:01.854 7fb42ded1f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 64075.890869, idle connection 3401.000000, request 304999.946356 06/15/2026 04:05:01.855 7fb42f4f1040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6503 06/15/2026 04:05:01.855 7fb42f4f1040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:01.855 7fb42f4f1040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6503 (677.6390075683594 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1285042058, topics=[]) 06/15/2026 04:05:01.855 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1285042058 with 0 response partitions (1 implied) 06/15/2026 04:05:01.856 7fb4314e7ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7075 06/15/2026 04:05:01.856 7fb4314e7ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:01.856 7fb4314e7ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7075 (643.9032554626465 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2075216190, topics=[]) 06/15/2026 04:05:01.856 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 2075216190 with 0 response partitions (1 implied) 06/15/2026 04:05:01.856 7fb42ded1f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 64073.979736, idle connection 3399.000000, request 304998.038769 06/15/2026 04:05:01.882 7fb42f4f1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63142.478027, idle connection 301939.000000, request 304399.000883 06/15/2026 04:05:01.882 7fb42f4f1b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6927 06/15/2026 04:05:01.882 7fb42f4f1b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:01.882 7fb42f4f1b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6927 (601.6814708709717 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=559822579, topics=[]) 06/15/2026 04:05:01.882 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 559822579 with 0 response partitions (1 implied) 06/15/2026 04:05:01.884 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 06/15/2026 04:05:01.884 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 06/15/2026 04:05:01.884 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 06/15/2026 04:05:01.884 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:05:01.884 7fb43147de00 [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=1410002452, session_epoch=6429, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:01.885 7fb43147de00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6456 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1410002452, session_epoch=6429, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:01.885 7fb43147de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 53915.199219, idle connection 334825.000000, request 304999.942064 06/15/2026 04:05:01.885 7fb43147de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 53914.719727, idle connection 334825.000000, request 304999.466419 06/15/2026 04:05:01.889 7fb42f4f1cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63465.202393, idle connection 2561.000000, request 304398.257494 06/15/2026 04:05:01.889 7fb42f4f1cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6954 06/15/2026 04:05:01.890 7fb42f4f1cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:01.890 7fb42f4f1cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 6954 (602.2739410400391 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2018373990, topics=[]) 06/15/2026 04:05:01.890 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2018373990 with 0 response partitions (1 implied) 06/15/2026 04:05:01.890 7fb42f4f1360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63243.030518, idle connection 1974.000000, request 304398.016930 06/15/2026 04:05:01.890 7fb42f4f1360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6605 06/15/2026 04:05:01.890 7fb42f4f1360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:01.891 7fb42f4f1360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6605 (602.3664474487305 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1864963515, topics=[]) 06/15/2026 04:05:01.891 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1864963515 with 0 response partitions (1 implied) 06/15/2026 04:05:01.990 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 716 06/15/2026 04:05:01.990 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 06/15/2026 04:05:01.990 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)]) 06/15/2026 04:05:01.990 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:01.990 7fb42f4f15e0 [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=1278530490, session_epoch=6603, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:01.990 7fb42f4f15e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 6622 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1278530490, session_epoch=6603, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:01.991 7fb42f4f15e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63758.999512, idle connection 1976.000000, request 304999.929190 06/15/2026 04:05:01.991 7fb42f4f15e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63758.342285, idle connection 1975.000000, request 304999.283791 06/15/2026 04:05:02.019 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 360 06/15/2026 04:05:02.019 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 06/15/2026 04:05:02.019 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 06/15/2026 04:05:02.019 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:02.020 7fb42f4f1900 [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=1464583258, session_epoch=6481, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:02.020 7fb42f4f1900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 6500 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1464583258, session_epoch=6481, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:02.020 7fb42f4f1900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59888.954590, idle connection 299887.000000, request 304999.934196 06/15/2026 04:05:02.020 7fb42f4f1900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59888.486328, idle connection 299886.000000, request 304999.474287 06/15/2026 04:05:02.134 7fb42f4f17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60184.137695, idle connection 300182.000000, request 304398.731947 06/15/2026 04:05:02.135 7fb42f4f17c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6514 06/15/2026 04:05:02.135 7fb42f4f17c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:02.135 7fb42f4f17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 6514 (601.7837524414062 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1679018624, topics=[]) 06/15/2026 04:05:02.135 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1679018624 with 0 response partitions (1 implied) 06/15/2026 04:05:02.455 7fb42e183ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 57175.967041, idle connection 297174.000000, request 304292.041779 06/15/2026 04:05:02.456 7fb42e183ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9941 06/15/2026 04:05:02.456 7fb42e183ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:02.456 7fb42e183ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 9941 (708.5230350494385 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=864390279, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=54990, last_stable_offset=54990, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xd6\xcd\x00\x00\x01\x04\x00\x00\x00\x00\x02\xc0K\x1d\xe6\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 06/15/2026 04:05:02.456 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 864390279 with 1 response partitions (0 implied) 06/15/2026 04:05:02.456 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 54989 06/15/2026 04:05:02.456 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 54989 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 06/15/2026 04:05:02.457 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 54990 (leader epoch 0) 06/15/2026 04:05:02.457 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 167 06/15/2026 04:05:02.457 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 06/15/2026 04:05:02.457 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 06/15/2026 04:05:02.457 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:05:02.457 7fb42f4f1040 [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=1285042058, session_epoch=6480, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:02.457 7fb42f4f1040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6504 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1285042058, session_epoch=6480, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:02.457 7fb42f4f1040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 57877.034424, idle connection 112591.000000, request 304999.953508 06/15/2026 04:05:02.457 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3850 06/15/2026 04:05:02.458 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 06/15/2026 04:05:02.458 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 06/15/2026 04:05:02.458 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:05:02.458 7fb4314e7ae0 [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=2075216190, session_epoch=7064, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:02.458 7fb4314e7ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7076 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2075216190, session_epoch=7064, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:02.458 7fb4314e7ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63214.002441, idle connection 1361.000000, request 304999.883890 06/15/2026 04:05:02.458 7fb42ded1f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63472.054443, idle connection 2797.000000, request 304396.115065 06/15/2026 04:05:02.459 7fb42f4f1040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 57875.754395, idle connection 112590.000000, request 304998.678684 06/15/2026 04:05:02.459 7fb4314e7ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63213.188721, idle connection 1360.000000, request 304999.075651 06/15/2026 04:05:02.459 7fb42ded1f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7149 06/15/2026 04:05:02.459 7fb42ded1f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:02.459 7fb42ded1f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7149 (604.804277420044 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=241006407, topics=[]) 06/15/2026 04:05:02.459 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 241006407 with 0 response partitions (1 implied) 06/15/2026 04:05:02.483 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 4357 06/15/2026 04:05:02.484 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 06/15/2026 04:05:02.484 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 06/15/2026 04:05:02.484 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/15/2026 04:05:02.484 7fb42f4f1b80 [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=559822579, session_epoch=6913, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:02.484 7fb42f4f1b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6928 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=559822579, session_epoch=6913, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:02.484 7fb42f4f1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62539.756836, idle connection 301336.000000, request 304999.945641 06/15/2026 04:05:02.485 7fb42f4f1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62539.355469, idle connection 301336.000000, request 304999.552488 06/15/2026 04:05:02.486 7fb43147de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 53313.558350, idle connection 334223.000000, request 304398.306847 06/15/2026 04:05:02.487 7fb43147de00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6456 06/15/2026 04:05:02.487 7fb43147de00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:02.487 7fb43147de00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6456 (602.0636558532715 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1410002452, topics=[]) 06/15/2026 04:05:02.487 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1410002452 with 0 response partitions (1 implied) 06/15/2026 04:05:02.491 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4380 06/15/2026 04:05:02.491 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 06/15/2026 04:05:02.491 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 06/15/2026 04:05:02.491 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:02.491 7fb42f4f1cc0 [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=2018373990, session_epoch=6933, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:02.492 7fb42f4f1cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 6955 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2018373990, session_epoch=6933, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:02.492 7fb42f4f1cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62862.722412, idle connection 1958.000000, request 304999.956131 06/15/2026 04:05:02.492 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 564 06/15/2026 04:05:02.492 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 06/15/2026 04:05:02.492 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 06/15/2026 04:05:02.492 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:05:02.492 7fb42f4f1360 [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=1864963515, session_epoch=6591, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:02.492 7fb42f4f1360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6606 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1864963515, session_epoch=6591, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:02.492 7fb42f4f1360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62640.827881, idle connection 1371.000000, request 304999.963045 06/15/2026 04:05:02.493 7fb42f4f1cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62861.704102, idle connection 1957.000000, request 304998.941898 06/15/2026 04:05:02.493 7fb42f4f1360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62640.213623, idle connection 1371.000000, request 304999.351978 06/15/2026 04:05:02.557 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 54990 06/15/2026 04:05:02.557 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 06/15/2026 04:05:02.557 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 06/15/2026 04:05:02.557 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:02.557 7fb42e183ea0 [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=864390279, session_epoch=9933, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=54990, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/15/2026 04:05:02.558 7fb42e183ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 9942 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=864390279, session_epoch=9933, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=54990, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/15/2026 04:05:02.558 7fb42e183ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 57073.446777, idle connection 297071.000000, request 304999.937057 06/15/2026 04:05:02.558 7fb42e183ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 57073.041504, idle connection 297071.000000, request 304999.539137 06/15/2026 04:05:02.592 7fb42f4f15e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63157.546631, idle connection 1375.000000, request 304398.484230 06/15/2026 04:05:02.592 7fb42f4f15e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6622 06/15/2026 04:05:02.592 7fb42f4f15e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:02.593 7fb42f4f15e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 6622 (602.0016670227051 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1278530490, topics=[]) 06/15/2026 04:05:02.593 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1278530490 with 0 response partitions (1 implied) 06/15/2026 04:05:02.621 7fb42f4f1900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59287.971436, idle connection 299286.000000, request 304398.945332 06/15/2026 04:05:02.621 7fb42f4f1900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6500 06/15/2026 04:05:02.621 7fb42f4f1900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:02.621 7fb42f4f1900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 6500 (601.546049118042 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1464583258, topics=[]) 06/15/2026 04:05:02.621 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1464583258 with 0 response partitions (1 implied) 06/15/2026 04:05:02.735 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 289 06/15/2026 04:05:02.735 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 06/15/2026 04:05:02.736 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 06/15/2026 04:05:02.736 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:02.736 7fb42f4f17c0 [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=1679018624, session_epoch=6494, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:02.736 7fb42f4f17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 6515 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1679018624, session_epoch=6494, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:02.736 7fb42f4f17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59582.343506, idle connection 299580.000000, request 304999.950886 06/15/2026 04:05:02.736 7fb42f4f17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59581.929443, idle connection 299580.000000, request 304999.543667 06/15/2026 04:05:03.060 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 4907 06/15/2026 04:05:03.060 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 06/15/2026 04:05:03.060 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 06/15/2026 04:05:03.060 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:05:03.060 7fb42ded1f40 [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=241006407, session_epoch=7132, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:03.060 7fb42ded1f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7150 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=241006407, session_epoch=7132, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:03.060 7fb42ded1f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62869.943115, idle connection 2195.000000, request 304999.947309 06/15/2026 04:05:03.061 7fb42f4f1040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 57273.687012, idle connection 111988.000000, request 304396.609545 06/15/2026 04:05:03.061 7fb4314e7ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62611.234863, idle connection 758.000000, request 304397.120953 06/15/2026 04:05:03.061 7fb42ded1f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62869.217773, idle connection 2194.000000, request 304999.230623 06/15/2026 04:05:03.061 7fb42f4f1040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6504 06/15/2026 04:05:03.061 7fb42f4f1040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:03.061 7fb42f4f1040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6504 (604.2132377624512 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1285042058, topics=[]) 06/15/2026 04:05:03.062 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1285042058 with 0 response partitions (1 implied) 06/15/2026 04:05:03.062 7fb4314e7ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7076 06/15/2026 04:05:03.062 7fb4314e7ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:03.062 7fb4314e7ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7076 (604.1221618652344 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2075216190, topics=[]) 06/15/2026 04:05:03.062 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 2075216190 with 0 response partitions (1 implied) 06/15/2026 04:05:03.085 7fb42f4f1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61938.835205, idle connection 300735.000000, request 304399.028540 06/15/2026 04:05:03.085 7fb42f4f1b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6928 06/15/2026 04:05:03.085 7fb42f4f1b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:03.086 7fb42f4f1b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6928 (601.405143737793 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=559822579, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=4359, last_stable_offset=4359, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x11\x05\x00\x00\x01\xfb\x00\x00\x00\x00\x02$\x92\xd2\xbd\x00\x00\x00\x00\x00\x01\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x02\xc6\x03\x00\x00\x00\x88\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 06/15/2026 04:05:03.086 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 559822579 with 1 response partitions (0 implied) 06/15/2026 04:05:03.086 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 519 bytes of data for partition TopicPartition(topic='-uve-topic-23', partition=0) with offset 4357 06/15/2026 04:05:03.086 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4357 for assigned partition TopicPartition(topic='-uve-topic-23', partition=0) 06/15/2026 04:05:03.086 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-23', partition=0) to 4359 (leader epoch 0) 06/15/2026 04:05:03.087 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 06/15/2026 04:05:03.087 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 06/15/2026 04:05:03.087 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 06/15/2026 04:05:03.087 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:05:03.087 7fb43147de00 [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=1410002452, session_epoch=6430, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:03.087 7fb43147de00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6457 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1410002452, session_epoch=6430, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:03.088 7fb43147de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 52712.328613, idle connection 333622.000000, request 304999.959946 06/15/2026 04:05:03.088 7fb43147de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 52711.985352, idle connection 333622.000000, request 304999.618769 06/15/2026 04:05:03.093 7fb42f4f1cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62261.081787, idle connection 1356.000000, request 304398.317814 06/15/2026 04:05:03.094 7fb42f4f1cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6955 06/15/2026 04:05:03.094 7fb42f4f1cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:03.094 7fb42f4f1cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 6955 (602.0493507385254 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2018373990, topics=[]) 06/15/2026 04:05:03.094 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2018373990 with 0 response partitions (1 implied) 06/15/2026 04:05:03.094 7fb42f4f1360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62039.200928, idle connection 770.000000, request 304398.337841 06/15/2026 04:05:03.094 7fb42f4f1360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6606 06/15/2026 04:05:03.094 7fb42f4f1360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:03.094 7fb42f4f1360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6606 (601.9587516784668 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1864963515, topics=[]) 06/15/2026 04:05:03.094 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1864963515 with 0 response partitions (1 implied) 06/15/2026 04:05:03.159 7fb42e183ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 56472.529053, idle connection 296470.000000, request 304399.012327 06/15/2026 04:05:03.159 7fb42e183ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9942 06/15/2026 04:05:03.159 7fb42e183ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:03.160 7fb42e183ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 9942 (601.8083095550537 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=864390279, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=54991, last_stable_offset=54991, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xd6\xce\x00\x00\x01\x04\x00\x00\x00\x00\x02\xed\x0e\xf2\x02\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 06/15/2026 04:05:03.160 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 864390279 with 1 response partitions (0 implied) 06/15/2026 04:05:03.160 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 54990 06/15/2026 04:05:03.160 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 54990 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 06/15/2026 04:05:03.161 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 54991 (leader epoch 0) 06/15/2026 04:05:03.188 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 4359 06/15/2026 04:05:03.188 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 06/15/2026 04:05:03.188 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-23', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 06/15/2026 04:05:03.188 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/15/2026 04:05:03.188 7fb42f4f1b80 [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=559822579, session_epoch=6914, topics=[(topic='-uve-topic-23', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4359, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/15/2026 04:05:03.188 7fb42f4f1b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6929 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=559822579, session_epoch=6914, topics=[(topic='-uve-topic-23', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4359, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/15/2026 04:05:03.189 7fb42f4f1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61835.389160, idle connection 300632.000000, request 304999.944448 06/15/2026 04:05:03.191 7fb42f4f1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61833.346680, idle connection 300630.000000, request 304997.908115 06/15/2026 04:05:03.193 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 716 06/15/2026 04:05:03.193 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 06/15/2026 04:05:03.193 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)]) 06/15/2026 04:05:03.193 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:03.194 7fb42f4f15e0 [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=1278530490, session_epoch=6604, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:03.194 7fb42f4f15e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 6623 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1278530490, session_epoch=6604, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:03.194 7fb42f4f15e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62555.772217, idle connection 773.000000, request 304999.944925 06/15/2026 04:05:03.194 7fb42f4f15e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62555.373535, idle connection 772.000000, request 304999.549389 06/15/2026 04:05:03.222 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 360 06/15/2026 04:05:03.222 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 06/15/2026 04:05:03.222 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 06/15/2026 04:05:03.223 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:03.223 7fb42f4f1900 [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=1464583258, session_epoch=6482, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:03.223 7fb42f4f1900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 6501 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1464583258, session_epoch=6482, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:03.223 7fb42f4f1900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 58685.694336, idle connection 298684.000000, request 304999.929905 06/15/2026 04:05:03.224 7fb42f4f1900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 58685.165283, idle connection 298683.000000, request 304999.407768 06/15/2026 04:05:03.261 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 54991 06/15/2026 04:05:03.262 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 06/15/2026 04:05:03.262 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 06/15/2026 04:05:03.262 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:03.262 7fb42e183ea0 [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=864390279, session_epoch=9934, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=54991, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/15/2026 04:05:03.262 7fb42e183ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 9943 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=864390279, session_epoch=9934, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=54991, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/15/2026 04:05:03.262 7fb42e183ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 56369.180908, idle connection 296367.000000, request 304999.947071 06/15/2026 04:05:03.263 7fb42e183ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 56368.756348, idle connection 296367.000000, request 304999.529600 06/15/2026 04:05:03.337 7fb42f4f17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 58981.432373, idle connection 298979.000000, request 304399.037123 06/15/2026 04:05:03.337 7fb42f4f17c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6515 06/15/2026 04:05:03.337 7fb42f4f17c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:03.337 7fb42f4f17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 6515 (601.473331451416 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1679018624, topics=[]) 06/15/2026 04:05:03.338 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1679018624 with 0 response partitions (1 implied) 06/15/2026 04:05:03.662 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 167 06/15/2026 04:05:03.662 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 06/15/2026 04:05:03.663 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 06/15/2026 04:05:03.663 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:05:03.663 7fb42f4f1040 [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=1285042058, session_epoch=6481, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:03.663 7fb42f4f1040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6505 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1285042058, session_epoch=6481, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:03.663 7fb42f4f1040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 56671.245605, idle connection 111385.000000, request 304999.929190 06/15/2026 04:05:03.664 7fb42f4f1040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 56670.814941, idle connection 111385.000000, request 304999.510050 06/15/2026 04:05:03.664 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3850 06/15/2026 04:05:03.664 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 06/15/2026 04:05:03.664 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 06/15/2026 04:05:03.664 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:05:03.664 7fb4314e7ae0 [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=2075216190, session_epoch=7065, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:03.664 7fb4314e7ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7077 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2075216190, session_epoch=7065, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:03.664 7fb4314e7ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62007.833496, idle connection 155.000000, request 304999.964237 06/15/2026 04:05:03.664 7fb42ded1f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62265.970215, idle connection 1591.000000, request 304395.982265 06/15/2026 04:05:03.665 7fb42ded1f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7150 06/15/2026 04:05:03.665 7fb42ded1f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:03.665 7fb42ded1f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7150 (604.4299602508545 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=241006407, topics=[]) 06/15/2026 04:05:03.665 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 241006407 with 0 response partitions (1 implied) 06/15/2026 04:05:03.665 7fb4314e7ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62006.812744, idle connection 154.000000, request 304998.945951 06/15/2026 04:05:03.689 7fb43147de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 52110.921387, idle connection 333021.000000, request 304398.547411 06/15/2026 04:05:03.689 7fb43147de00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6457 06/15/2026 04:05:03.689 7fb43147de00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:03.689 7fb43147de00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6457 (601.9341945648193 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1410002452, topics=[]) 06/15/2026 04:05:03.690 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1410002452 with 0 response partitions (1 implied) 06/15/2026 04:05:03.694 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4380 06/15/2026 04:05:03.694 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 06/15/2026 04:05:03.694 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 06/15/2026 04:05:03.694 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:03.694 7fb42f4f1cc0 [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=2018373990, session_epoch=6934, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:03.695 7fb42f4f1cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 6956 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2018373990, session_epoch=6934, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:03.695 7fb42f4f1cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61659.629883, idle connection 755.000000, request 304999.954939 06/15/2026 04:05:03.695 7fb42f4f1cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61659.252930, idle connection 755.000000, request 304999.583244 06/15/2026 04:05:03.696 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 564 06/15/2026 04:05:03.696 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 06/15/2026 04:05:03.696 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 06/15/2026 04:05:03.696 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:05:03.696 7fb42f4f1360 [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=1864963515, session_epoch=6592, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:03.696 7fb42f4f1360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6607 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1864963515, session_epoch=6592, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:03.696 7fb42f4f1360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61436.782227, idle connection 167.000000, request 304999.963045 06/15/2026 04:05:03.697 7fb42f4f1360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61436.469971, idle connection 167.000000, request 304999.653339 06/15/2026 04:05:03.791 7fb42f4f1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61232.699707, idle connection 300029.000000, request 304397.255421 06/15/2026 04:05:03.792 7fb42f4f1b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6929 06/15/2026 04:05:03.792 7fb42f4f1b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:03.792 7fb42f4f1b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6929 (603.2426357269287 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=559822579, topics=[]) 06/15/2026 04:05:03.792 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 559822579 with 0 response partitions (1 implied) 06/15/2026 04:05:03.795 7fb42f4f15e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61955.003662, idle connection 172.000000, request 304399.177313 06/15/2026 04:05:03.795 7fb42f4f15e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6623 06/15/2026 04:05:03.795 7fb42f4f15e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:03.795 7fb42f4f15e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 6623 (601.1769771575928 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1278530490, topics=[]) 06/15/2026 04:05:03.795 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1278530490 with 0 response partitions (1 implied) 06/15/2026 04:05:03.824 7fb42f4f1900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 58084.507568, idle connection 298082.000000, request 304398.746252 06/15/2026 04:05:03.825 7fb42f4f1900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6501 06/15/2026 04:05:03.825 7fb42f4f1900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:03.825 7fb42f4f1900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 6501 (601.7379760742188 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1464583258, topics=[]) 06/15/2026 04:05:03.825 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1464583258 with 0 response partitions (1 implied) 06/15/2026 04:05:03.863 7fb42e183ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 55768.257568, idle connection 295766.000000, request 304399.023771 06/15/2026 04:05:03.863 7fb42e183ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9943 06/15/2026 04:05:03.863 7fb42e183ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:03.864 7fb42e183ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 9943 (601.4697551727295 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=864390279, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=54992, last_stable_offset=54992, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xd6\xcf\x00\x00\x01\x02\x00\x00\x00\x00\x02\t\xed?\xdb\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\x9e\x03\x00\x00\x00\xe0\x02ObjectCollectorInfo:cn-jenkins-d...')])]) 06/15/2026 04:05:03.864 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 864390279 with 1 response partitions (0 implied) 06/15/2026 04:05:03.864 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 270 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 54991 06/15/2026 04:05:03.864 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 54991 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 06/15/2026 04:05:03.864 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 54992 (leader epoch 0) 06/15/2026 04:05:03.938 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 289 06/15/2026 04:05:03.939 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 06/15/2026 04:05:03.939 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 06/15/2026 04:05:03.939 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:03.939 7fb42f4f17c0 [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=1679018624, session_epoch=6495, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:03.939 7fb42f4f17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 6516 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1679018624, session_epoch=6495, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:03.939 7fb42f4f17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 58378.887207, idle connection 298377.000000, request 304999.930859 06/15/2026 04:05:03.940 7fb42f4f17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 58378.326416, idle connection 298376.000000, request 304999.381542 06/15/2026 04:05:03.965 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 54992 06/15/2026 04:05:03.965 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 06/15/2026 04:05:03.965 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 06/15/2026 04:05:03.966 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:03.966 7fb42e183ea0 [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=864390279, session_epoch=9935, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=54992, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/15/2026 04:05:03.966 7fb42e183ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 9944 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=864390279, session_epoch=9935, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=54992, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/15/2026 04:05:03.966 7fb42e183ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 55665.153320, idle connection 295663.000000, request 304999.933004 06/15/2026 04:05:03.967 7fb42e183ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 55664.616455, idle connection 295662.000000, request 304999.408007 06/15/2026 04:05:04.265 7fb42f4f1040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 56069.495361, idle connection 110783.000000, request 304398.181438 06/15/2026 04:05:04.265 7fb42f4f1040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6505 06/15/2026 04:05:04.265 7fb42f4f1040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:04.265 7fb42f4f1040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6505 (602.4167537689209 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1285042058, topics=[]) 06/15/2026 04:05:04.266 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1285042058 with 0 response partitions (1 implied) 06/15/2026 04:05:04.266 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 4907 06/15/2026 04:05:04.266 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 06/15/2026 04:05:04.266 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 06/15/2026 04:05:04.266 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:05:04.266 7fb42ded1f40 [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=241006407, session_epoch=7133, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:04.266 7fb42ded1f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7151 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=241006407, session_epoch=7133, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:04.266 7fb42ded1f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61663.975098, idle connection 989.000000, request 304999.959230 06/15/2026 04:05:04.267 7fb4314e7ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61405.484619, idle connection 0.000000, request 304397.617340 06/15/2026 04:05:04.267 7fb4314e7ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7077 06/15/2026 04:05:04.267 7fb4314e7ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:04.267 7fb4314e7ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7077 (602.6923656463623 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2075216190, topics=[]) 06/15/2026 04:05:04.267 7fb4314e7ae0 [kafka.client] [INFO]: Closing idle connection 1, last active 540447 ms ago 06/15/2026 04:05:04.267 7fb4314e7ae0 [kafka.conn] [INFO]: [IPv4 ('10.0.0.23', 9092)]>: Closing connection. 06/15/2026 04:05:04.267 7fb4314e7ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: reconnect backoff 0.040251811500850186 after 1 failures 06/15/2026 04:05:04.267 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 2075216190 with 0 response partitions (1 implied) 06/15/2026 04:05:04.268 7fb42ded1f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61662.710693, idle connection 988.000000, request 304998.697519 06/15/2026 04:05:04.290 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 06/15/2026 04:05:04.290 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 06/15/2026 04:05:04.290 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 06/15/2026 04:05:04.290 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:05:04.290 7fb43147de00 [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=1410002452, session_epoch=6431, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:04.290 7fb43147de00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6458 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1410002452, session_epoch=6431, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:04.291 7fb43147de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 51509.342285, idle connection 332419.000000, request 304999.955416 06/15/2026 04:05:04.291 7fb43147de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 51508.989502, idle connection 332419.000000, request 304999.607325 06/15/2026 04:05:04.296 7fb42f4f1cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61058.745361, idle connection 154.000000, request 304399.067163 06/15/2026 04:05:04.296 7fb42f4f1cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6956 06/15/2026 04:05:04.296 7fb42f4f1cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:04.296 7fb42f4f1cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 6956 (601.647138595581 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2018373990, topics=[]) 06/15/2026 04:05:04.297 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2018373990 with 0 response partitions (1 implied) 06/15/2026 04:05:04.297 7fb42f4f1360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60836.067139, idle connection 0.000000, request 304399.244547 06/15/2026 04:05:04.297 7fb42f4f1360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6607 06/15/2026 04:05:04.297 7fb42f4f1360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:04.298 7fb42f4f1360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6607 (601.2375354766846 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1864963515, topics=[]) 06/15/2026 04:05:04.298 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1864963515 with 0 response partitions (1 implied) 06/15/2026 04:05:04.393 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 4359 06/15/2026 04:05:04.393 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 06/15/2026 04:05:04.393 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 06/15/2026 04:05:04.393 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/15/2026 04:05:04.393 7fb42f4f1b80 [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=559822579, session_epoch=6915, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:04.394 7fb42f4f1b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6930 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=559822579, session_epoch=6915, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:04.394 7fb42f4f1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60630.179932, idle connection 299427.000000, request 304999.908447 06/15/2026 04:05:04.394 7fb42f4f1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60629.580566, idle connection 299426.000000, request 304999.331951 06/15/2026 04:05:04.396 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 716 06/15/2026 04:05:04.396 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 06/15/2026 04:05:04.396 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)]) 06/15/2026 04:05:04.396 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:04.396 7fb42f4f15e0 [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=1278530490, session_epoch=6605, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:04.396 7fb42f4f15e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 6624 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1278530490, session_epoch=6605, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:04.397 7fb42f4f15e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61352.911133, idle connection 0.000000, request 304999.940634 06/15/2026 04:05:04.397 7fb42f4f15e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61352.314209, idle connection 301350.000000, request 304999.346972 06/15/2026 04:05:04.426 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 360 06/15/2026 04:05:04.426 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 06/15/2026 04:05:04.427 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 06/15/2026 04:05:04.427 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:04.427 7fb42f4f1900 [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=1464583258, session_epoch=6483, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:04.427 7fb42f4f1900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 6502 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1464583258, session_epoch=6483, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:04.427 7fb42f4f1900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 57481.447266, idle connection 297479.000000, request 304999.924421 06/15/2026 04:05:04.428 7fb42f4f1900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 57480.844482, idle connection 297479.000000, request 304999.329329 06/15/2026 04:05:04.541 7fb42f4f17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 57777.633545, idle connection 297776.000000, request 304398.676872 06/15/2026 04:05:04.541 7fb42f4f17c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6516 06/15/2026 04:05:04.541 7fb42f4f17c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:04.542 7fb42f4f17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 6516 (602.1401882171631 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1679018624, topics=[]) 06/15/2026 04:05:04.542 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1679018624 with 0 response partitions (1 implied) 06/15/2026 04:05:04.567 7fb42e183ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 55063.965332, idle connection 295062.000000, request 304398.741484 06/15/2026 04:05:04.568 7fb42e183ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9944 06/15/2026 04:05:04.568 7fb42e183ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:04.568 7fb42e183ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 9944 (602.2193431854248 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=864390279, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=54994, last_stable_offset=54994, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xd6\xd0\x00\x00\x01\x02\x00\x00\x00\x00\x02F\xf5e9\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\x9e\x03\x00\x00\x00\xe0\x02ObjectCollectorInfo:cn-jenkins-d...')])]) 06/15/2026 04:05:04.569 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 864390279 with 1 response partitions (0 implied) 06/15/2026 04:05:04.569 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 540 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 54992 06/15/2026 04:05:04.569 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 54992 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 06/15/2026 04:05:04.569 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 54994 (leader epoch 0) 06/15/2026 04:05:04.671 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 54994 06/15/2026 04:05:04.671 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 06/15/2026 04:05:04.671 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 06/15/2026 04:05:04.671 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:04.671 7fb42e183ea0 [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=864390279, session_epoch=9936, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=54994, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/15/2026 04:05:04.671 7fb42e183ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 9945 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=864390279, session_epoch=9936, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=54994, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/15/2026 04:05:04.671 7fb42e183ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 54960.002441, idle connection 294958.000000, request 304999.948025 06/15/2026 04:05:04.672 7fb42e183ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 54959.600586, idle connection 294957.000000, request 304999.553442 06/15/2026 04:05:04.866 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 167 06/15/2026 04:05:04.866 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 06/15/2026 04:05:04.866 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 06/15/2026 04:05:04.866 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:05:04.867 7fb42f4f1040 [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=1285042058, session_epoch=6482, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:04.867 7fb42f4f1040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6506 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1285042058, session_epoch=6482, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:04.867 7fb42f4f1040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 55467.500244, idle connection 110181.000000, request 304999.946356 06/15/2026 04:05:04.867 7fb42f4f1040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 55466.979004, idle connection 110181.000000, request 304999.432802 06/15/2026 04:05:04.868 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3850 06/15/2026 04:05:04.868 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 06/15/2026 04:05:04.868 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 06/15/2026 04:05:04.868 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:05:04.868 7fb4314e7ae0 [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=2075216190, session_epoch=7066, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:04.868 7fb4314e7ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7078 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2075216190, session_epoch=7066, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:04.868 7fb4314e7ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60803.881104, idle connection 0.000000, request 304999.957561 06/15/2026 04:05:04.868 7fb42ded1f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61061.966797, idle connection 387.000000, request 304397.952795 06/15/2026 04:05:04.869 7fb4314e7ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60803.397461, idle connection 539398.000000, request 304999.479055 06/15/2026 04:05:04.869 7fb42ded1f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7151 06/15/2026 04:05:04.869 7fb42ded1f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:04.869 7fb42ded1f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7151 (602.6804447174072 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=241006407, topics=[]) 06/15/2026 04:05:04.869 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 241006407 with 0 response partitions (1 implied) 06/15/2026 04:05:04.891 7fb43147de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 50908.472656, idle connection 331818.000000, request 304399.080992 06/15/2026 04:05:04.892 7fb43147de00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6458 06/15/2026 04:05:04.892 7fb43147de00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:04.892 7fb43147de00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6458 (601.4308929443359 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1410002452, topics=[]) 06/15/2026 04:05:04.892 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1410002452 with 0 response partitions (1 implied) 06/15/2026 04:05:04.897 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4380 06/15/2026 04:05:04.897 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 06/15/2026 04:05:04.897 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 06/15/2026 04:05:04.897 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:04.897 7fb42f4f1cc0 [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=2018373990, session_epoch=6935, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:04.898 7fb42f4f1cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 6957 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2018373990, session_epoch=6935, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:04.898 7fb42f4f1cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60456.617188, idle connection 0.000000, request 304999.950409 06/15/2026 04:05:04.898 7fb42f4f1cc0 [kafka.client] [INFO]: Closing idle connection 2, last active 540447 ms ago 06/15/2026 04:05:04.898 7fb42f4f1cc0 [kafka.conn] [INFO]: [IPv4 ('10.0.0.33', 9092)]>: Closing connection. 06/15/2026 04:05:04.898 7fb42f4f1cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: reconnect backoff 0.05321725571293866 after 1 failures 06/15/2026 04:05:04.899 7fb42f4f1cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60455.453857, idle connection 0.000000, request 304998.784065 06/15/2026 04:05:04.899 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 564 06/15/2026 04:05:04.899 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 06/15/2026 04:05:04.899 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 06/15/2026 04:05:04.899 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:05:04.899 7fb42f4f1360 [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=1864963515, session_epoch=6593, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:04.900 7fb42f4f1360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6608 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1864963515, session_epoch=6593, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:04.900 7fb42f4f1360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60233.543213, idle connection 300231.000000, request 304999.961853 06/15/2026 04:05:04.900 7fb42f4f1360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60233.025146, idle connection 300231.000000, request 304999.445915 06/15/2026 04:05:04.997 7fb42f4f1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60027.097900, idle connection 298824.000000, request 304396.849155 06/15/2026 04:05:04.997 7fb42f4f1b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6930 06/15/2026 04:05:04.997 7fb42f4f1b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:04.997 7fb42f4f1b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6930 (603.5878658294678 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=559822579, topics=[]) 06/15/2026 04:05:04.997 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 559822579 with 0 response partitions (1 implied) 06/15/2026 04:05:04.998 7fb42f4f15e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60751.680176, idle connection 300749.000000, request 304398.715258 06/15/2026 04:05:04.998 7fb42f4f15e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6624 06/15/2026 04:05:04.998 7fb42f4f15e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:04.998 7fb42f4f15e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 6624 (601.6464233398438 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1278530490, topics=[]) 06/15/2026 04:05:04.998 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1278530490 with 0 response partitions (1 implied) 06/15/2026 04:05:05.029 7fb42f4f1900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 56880.120361, idle connection 296878.000000, request 304398.601294 06/15/2026 04:05:05.029 7fb42f4f1900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6502 06/15/2026 04:05:05.029 7fb42f4f1900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:05.029 7fb42f4f1900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 6502 (601.975679397583 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1464583258, topics=[]) 06/15/2026 04:05:05.029 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1464583258 with 0 response partitions (1 implied) 06/15/2026 04:05:05.144 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 289 06/15/2026 04:05:05.144 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 06/15/2026 04:05:05.144 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 06/15/2026 04:05:05.144 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:05.145 7fb42f4f17c0 [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=1679018624, session_epoch=6496, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:05.145 7fb42f4f17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 6517 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1679018624, session_epoch=6496, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:05.145 7fb42f4f17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 57173.530762, idle connection 297171.000000, request 304999.924421 06/15/2026 04:05:05.145 7fb42f4f17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 57173.117676, idle connection 297171.000000, request 304999.519587 06/15/2026 04:05:05.272 7fb42e183ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 54359.076416, idle connection 294357.000000, request 304399.019241 06/15/2026 04:05:05.273 7fb42e183ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9945 06/15/2026 04:05:05.273 7fb42e183ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:05.273 7fb42e183ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 9945 (601.5255451202393 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=864390279, topics=[]) 06/15/2026 04:05:05.273 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 864390279 with 0 response partitions (1 implied) 06/15/2026 04:05:05.468 7fb42f4f1040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 54866.375977, idle connection 109580.000000, request 304398.811817 06/15/2026 04:05:05.468 7fb42f4f1040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6506 06/15/2026 04:05:05.469 7fb42f4f1040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:05.469 7fb42f4f1040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6506 (601.8404960632324 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1285042058, topics=[]) 06/15/2026 04:05:05.469 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1285042058 with 0 response partitions (1 implied) 06/15/2026 04:05:05.470 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 4907 06/15/2026 04:05:05.470 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 06/15/2026 04:05:05.470 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 06/15/2026 04:05:05.470 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:05:05.470 7fb42ded1f40 [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=241006407, session_epoch=7134, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:05.470 7fb42ded1f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7152 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=241006407, session_epoch=7134, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:05.470 7fb42ded1f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60460.237549, idle connection 0.000000, request 304999.953985 06/15/2026 04:05:05.470 7fb4314e7ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60201.708740, idle connection 538796.000000, request 304397.789001 06/15/2026 04:05:05.471 7fb42ded1f40 [kafka.client] [INFO]: Closing idle connection 3, last active 540214 ms ago 06/15/2026 04:05:05.471 7fb42ded1f40 [kafka.conn] [INFO]: [IPv4 ('10.0.0.65', 9092)]>: Closing connection. 06/15/2026 04:05:05.471 7fb42ded1f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: reconnect backoff 0.05905419170354793 after 1 failures 06/15/2026 04:05:05.471 7fb42ded1f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60459.113770, idle connection 0.000000, request 304998.832464 06/15/2026 04:05:05.471 7fb4314e7ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7078 06/15/2026 04:05:05.472 7fb4314e7ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:05.472 7fb4314e7ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7078 (603.4739017486572 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2075216190, topics=[]) 06/15/2026 04:05:05.472 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 2075216190 with 0 response partitions (1 implied) 06/15/2026 04:05:05.494 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 06/15/2026 04:05:05.494 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 06/15/2026 04:05:05.494 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 06/15/2026 04:05:05.494 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:05:05.495 7fb43147de00 [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=1410002452, session_epoch=6432, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:05.495 7fb43147de00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6459 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1410002452, session_epoch=6432, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:05.495 7fb43147de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 50305.068115, idle connection 331215.000000, request 304999.947548 06/15/2026 04:05:05.495 7fb43147de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 50304.551025, idle connection 331214.000000, request 304999.438047 06/15/2026 04:05:05.500 7fb42f4f1cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59854.306885, idle connection 538795.000000, request 304397.644281 06/15/2026 04:05:05.500 7fb42f4f1cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6957 06/15/2026 04:05:05.500 7fb42f4f1cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:05.500 7fb42f4f1cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 6957 (602.7660369873047 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2018373990, topics=[]) 06/15/2026 04:05:05.501 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2018373990 with 0 response partitions (1 implied) 06/15/2026 04:05:05.503 7fb42f4f1360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59629.761475, idle connection 299628.000000, request 304396.179914 06/15/2026 04:05:05.504 7fb42f4f1360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6608 06/15/2026 04:05:05.504 7fb42f4f1360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:05.504 7fb42f4f1360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6608 (604.1831970214844 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1864963515, topics=[]) 06/15/2026 04:05:05.504 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1864963515 with 0 response partitions (1 implied) 06/15/2026 04:05:05.599 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 4359 06/15/2026 04:05:05.599 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 06/15/2026 04:05:05.599 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 06/15/2026 04:05:05.600 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/15/2026 04:05:05.600 7fb42f4f1b80 [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=559822579, session_epoch=6916, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:05.600 7fb42f4f1b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6931 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=559822579, session_epoch=6916, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:05.600 7fb42f4f1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59424.013916, idle connection 298220.000000, request 304999.941587 06/15/2026 04:05:05.600 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 716 06/15/2026 04:05:05.600 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 06/15/2026 04:05:05.600 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)]) 06/15/2026 04:05:05.600 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:05.601 7fb42f4f15e0 [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=1278530490, session_epoch=6606, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:05.601 7fb42f4f15e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 6625 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1278530490, session_epoch=6606, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:05.601 7fb42f4f15e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60148.794922, idle connection 300147.000000, request 304999.939203 06/15/2026 04:05:05.601 7fb42f4f1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59422.782715, idle connection 298219.000000, request 304998.716354 06/15/2026 04:05:05.602 7fb42f4f15e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60147.989258, idle connection 300146.000000, request 304999.160290 06/15/2026 04:05:05.630 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 360 06/15/2026 04:05:05.630 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 06/15/2026 04:05:05.631 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 06/15/2026 04:05:05.631 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:05.631 7fb42f4f1900 [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=1464583258, session_epoch=6484, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:05.631 7fb42f4f1900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 6503 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1464583258, session_epoch=6484, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:05.631 7fb42f4f1900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 56277.396973, idle connection 296275.000000, request 304999.945164 06/15/2026 04:05:05.632 7fb42f4f1900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 56276.990723, idle connection 296275.000000, request 304999.547243 06/15/2026 04:05:05.746 7fb42f4f17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 56572.617676, idle connection 296571.000000, request 304399.010897 06/15/2026 04:05:05.746 7fb42f4f17c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6517 06/15/2026 04:05:05.746 7fb42f4f17c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:05.746 7fb42f4f17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 6517 (601.5889644622803 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1679018624, topics=[]) 06/15/2026 04:05:05.747 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1679018624 with 0 response partitions (1 implied) 06/15/2026 04:05:05.873 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 54994 06/15/2026 04:05:05.874 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 06/15/2026 04:05:05.874 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 06/15/2026 04:05:05.874 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:05.874 7fb42e183ea0 [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=864390279, session_epoch=9937, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:05.874 7fb42e183ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 9946 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=864390279, session_epoch=9937, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:05.874 7fb42e183ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 53756.974365, idle connection 293755.000000, request 304999.948502 06/15/2026 04:05:05.875 7fb42e183ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 53756.562500, idle connection 293754.000000, request 304999.540329 06/15/2026 04:05:06.069 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 167 06/15/2026 04:05:06.070 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 06/15/2026 04:05:06.070 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 06/15/2026 04:05:06.070 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:05:06.070 7fb42f4f1040 [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=1285042058, session_epoch=6483, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:06.070 7fb42f4f1040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6507 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1285042058, session_epoch=6483, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:06.070 7fb42f4f1040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 54264.172852, idle connection 108978.000000, request 304999.950171 06/15/2026 04:05:06.071 7fb42f4f1040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 54263.677734, idle connection 108978.000000, request 304999.461889 06/15/2026 04:05:06.073 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 3850 06/15/2026 04:05:06.073 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 06/15/2026 04:05:06.073 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 06/15/2026 04:05:06.073 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:05:06.073 7fb4314e7ae0 [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=2075216190, session_epoch=7067, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:06.073 7fb4314e7ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7079 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2075216190, session_epoch=7067, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:06.073 7fb4314e7ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59598.859619, idle connection 538193.000000, request 304999.956846 06/15/2026 04:05:06.073 7fb42ded1f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59856.953369, idle connection 538795.000000, request 304396.673203 06/15/2026 04:05:06.074 7fb4314e7ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59598.317383, idle connection 538192.000000, request 304999.418497 06/15/2026 04:05:06.074 7fb42ded1f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7152 06/15/2026 04:05:06.074 7fb42ded1f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:06.074 7fb42ded1f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7152 (604.1257381439209 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=241006407, topics=[]) 06/15/2026 04:05:06.074 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 241006407 with 0 response partitions (1 implied) 06/15/2026 04:05:06.097 7fb43147de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 49702.909668, idle connection 330613.000000, request 304397.787333 06/15/2026 04:05:06.097 7fb43147de00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6459 06/15/2026 04:05:06.098 7fb43147de00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:06.098 7fb43147de00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6459 (602.7956008911133 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1410002452, topics=[]) 06/15/2026 04:05:06.098 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1410002452 with 0 response partitions (1 implied) 06/15/2026 04:05:06.101 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4380 06/15/2026 04:05:06.102 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 06/15/2026 04:05:06.102 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 06/15/2026 04:05:06.102 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:06.102 7fb42f4f1cc0 [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=2018373990, session_epoch=6936, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:06.102 7fb42f4f1cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 6958 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2018373990, session_epoch=6936, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:06.102 7fb42f4f1cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59252.142334, idle connection 538193.000000, request 304999.950886 06/15/2026 04:05:06.103 7fb42f4f1cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59251.775635, idle connection 538193.000000, request 304999.589682 06/15/2026 04:05:06.105 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 564 06/15/2026 04:05:06.105 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 06/15/2026 04:05:06.105 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 06/15/2026 04:05:06.105 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:05:06.105 7fb42f4f1360 [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=1864963515, session_epoch=6594, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:06.106 7fb42f4f1360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6609 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1864963515, session_epoch=6594, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:06.106 7fb42f4f1360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59027.533203, idle connection 299025.000000, request 304999.960661 06/15/2026 04:05:06.106 7fb42f4f1360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59027.104492, idle connection 299025.000000, request 304999.531984 06/15/2026 04:05:06.202 7fb42f4f1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 58821.903076, idle connection 297618.000000, request 304397.829771 06/15/2026 04:05:06.202 7fb42f4f1b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6931 06/15/2026 04:05:06.202 7fb42f4f1b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:06.203 7fb42f4f1b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6931 (602.6747226715088 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=559822579, topics=[]) 06/15/2026 04:05:06.203 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 559822579 with 0 response partitions (1 implied) 06/15/2026 04:05:06.203 7fb42f4f15e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59546.627930, idle connection 299544.000000, request 304397.796154 06/15/2026 04:05:06.203 7fb42f4f15e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6625 06/15/2026 04:05:06.203 7fb42f4f15e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:06.203 7fb42f4f15e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 6625 (602.576494216919 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1278530490, topics=[]) 06/15/2026 04:05:06.203 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1278530490 with 0 response partitions (1 implied) 06/15/2026 04:05:06.232 7fb42f4f1900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 55676.484375, idle connection 295674.000000, request 304399.033308 06/15/2026 04:05:06.233 7fb42f4f1900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6503 06/15/2026 04:05:06.233 7fb42f4f1900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:06.233 7fb42f4f1900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 6503 (601.4590263366699 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1464583258, topics=[]) 06/15/2026 04:05:06.233 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1464583258 with 0 response partitions (1 implied) 06/15/2026 04:05:06.347 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 289 06/15/2026 04:05:06.347 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 06/15/2026 04:05:06.347 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 06/15/2026 04:05:06.347 7fb42f4f17c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:06.348 7fb42f4f17c0 [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=1679018624, session_epoch=6497, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:06.348 7fb42f4f17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 6518 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1679018624, session_epoch=6497, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:06.348 7fb42f4f17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 55970.505615, idle connection 295968.000000, request 304999.947786 06/15/2026 04:05:06.348 7fb42f4f17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 55970.095947, idle connection 295968.000000, request 304999.546051 06/15/2026 04:05:06.476 7fb42e183ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 53155.760010, idle connection 293154.000000, request 304398.733854 06/15/2026 04:05:06.476 7fb42e183ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9946 06/15/2026 04:05:06.476 7fb42e183ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:06.476 7fb42e183ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 9946 (601.8445491790771 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=864390279, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=54995, last_stable_offset=54995, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xd6\xd2\x00\x00\x01\x04\x00\x00\x00\x00\x02,\xcc6\xe7\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 06/15/2026 04:05:06.476 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 864390279 with 1 response partitions (0 implied) 06/15/2026 04:05:06.476 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 54994 06/15/2026 04:05:06.477 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 54994 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 06/15/2026 04:05:06.477 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 54995 (leader epoch 0) 06/15/2026 04:05:06.577 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 54995 06/15/2026 04:05:06.578 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 06/15/2026 04:05:06.578 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 06/15/2026 04:05:06.578 7fb42e183ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:06.578 7fb42e183ea0 [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=864390279, session_epoch=9938, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=54995, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/15/2026 04:05:06.578 7fb42e183ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 9947 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=864390279, session_epoch=9938, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=54995, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/15/2026 04:05:06.578 7fb42e183ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 53053.125488, idle connection 293051.000000, request 304999.946356 06/15/2026 04:05:06.579 7fb42e183ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 53052.723145, idle connection 293051.000000, request 304999.551535 06/15/2026 04:05:06.671 7fb42f4f1040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 53663.086426, idle connection 108377.000000, request 304398.861885 06/15/2026 04:05:06.672 7fb42f4f1040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6507 06/15/2026 04:05:06.672 7fb42f4f1040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:06.672 7fb42f4f1040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6507 (601.8130779266357 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1285042058, topics=[]) 06/15/2026 04:05:06.672 7fb42f4f1040 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1285042058 with 0 response partitions (1 implied) 06/15/2026 04:05:06.675 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 4907 06/15/2026 04:05:06.675 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 06/15/2026 04:05:06.675 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 06/15/2026 04:05:06.675 7fb42ded1f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:05:06.675 7fb42ded1f40 [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=241006407, session_epoch=7135, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:06.675 7fb42ded1f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7153 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=241006407, session_epoch=7135, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:06.676 7fb42ded1f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59254.843750, idle connection 538193.000000, request 304999.940395 06/15/2026 04:05:06.676 7fb4314e7ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 58996.232666, idle connection 537590.000000, request 304397.331476 06/15/2026 04:05:06.676 7fb42ded1f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59254.123779, idle connection 538192.000000, request 304999.226093 06/15/2026 04:05:06.676 7fb4314e7ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7079 06/15/2026 04:05:06.677 7fb4314e7ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:06.677 7fb4314e7ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7079 (603.548526763916 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2075216190, topics=[]) 06/15/2026 04:05:06.677 7fb4314e7ae0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 2075216190 with 0 response partitions (1 implied) 06/15/2026 04:05:06.698 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 06/15/2026 04:05:06.698 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 06/15/2026 04:05:06.698 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 06/15/2026 04:05:06.699 7fb43147de00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/15/2026 04:05:06.699 7fb43147de00 [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=1410002452, session_epoch=6433, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:06.699 7fb43147de00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6460 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1410002452, session_epoch=6433, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:06.699 7fb43147de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 49100.998535, idle connection 330011.000000, request 304999.948025 06/15/2026 04:05:06.699 7fb43147de00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 49100.602295, idle connection 330010.000000, request 304999.559402 06/15/2026 04:05:06.703 7fb42f4f1cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 58651.161133, idle connection 537592.000000, request 304398.972988 06/15/2026 04:05:06.704 7fb42f4f1cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6958 06/15/2026 04:05:06.704 7fb42f4f1cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:06.704 7fb42f4f1cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Response 6958 (601.5186309814453 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2018373990, topics=[]) 06/15/2026 04:05:06.704 7fb42f4f1cc0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2018373990 with 0 response partitions (1 implied) 06/15/2026 04:05:06.706 7fb42f4f1360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 58426.751709, idle connection 298425.000000, request 304399.177074 06/15/2026 04:05:06.707 7fb42f4f1360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6609 06/15/2026 04:05:06.707 7fb42f4f1360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/15/2026 04:05:06.707 7fb42f4f1360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6609 (601.1977195739746 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1864963515, topics=[]) 06/15/2026 04:05:06.707 7fb42f4f1360 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1864963515 with 0 response partitions (1 implied) 06/15/2026 04:05:06.804 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 4359 06/15/2026 04:05:06.804 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 06/15/2026 04:05:06.804 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 06/15/2026 04:05:06.804 7fb42f4f1b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/15/2026 04:05:06.805 7fb42f4f1b80 [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=559822579, session_epoch=6917, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:06.805 7fb42f4f1b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6932 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=559822579, session_epoch=6917, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:06.805 7fb42f4f1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 58219.129639, idle connection 297016.000000, request 304999.935865 06/15/2026 04:05:06.805 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 716 06/15/2026 04:05:06.805 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 06/15/2026 04:05:06.805 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)]) 06/15/2026 04:05:06.805 7fb42f4f15e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:06.805 7fb42f4f15e0 [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=1278530490, session_epoch=6607, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:06.805 7fb42f4f15e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 6626 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1278530490, session_epoch=6607, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:06.805 7fb42f4f15e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 58944.082031, idle connection 298942.000000, request 304999.965429 06/15/2026 04:05:06.806 7fb42f4f1b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 58218.017578, idle connection 297014.000000, request 304998.833179 06/15/2026 04:05:06.806 7fb42f4f15e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 58943.362793, idle connection 298941.000000, request 304999.248743 06/15/2026 04:05:06.834 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 360 06/15/2026 04:05:06.834 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 06/15/2026 04:05:06.834 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 06/15/2026 04:05:06.834 7fb42f4f1900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/15/2026 04:05:06.834 7fb42f4f1900 [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=1464583258, session_epoch=6485, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:06.834 7fb42f4f1900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.65', 9092)]>: Request 6504 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1464583258, session_epoch=6485, topics=[], forgotten_topics_data=[]) 06/15/2026 04:05:06.835 7fb42f4f1900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 55074.156250, idle connection 295072.000000, request 304999.949217 06/15/2026 04:05:06.835 7fb42f4f1900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 55073.738770, idle connection 295072.000000, request 304999.538898