06/18/2026 04:05:50.706 7fbdb01b2cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 262667.608154, idle connection 440059.000000, request 304396.625280 06/18/2026 04:05:50.706 7fbdb01b2cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6320 06/18/2026 04:05:50.706 7fbdb01b2cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:50.707 7fbdb01b2cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6320 (604.4025421142578 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1059026835, topics=[]) 06/18/2026 04:05:50.707 7fbdb01b2cc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1059026835 with 0 response partitions (1 implied) 06/18/2026 04:05:50.707 7fbdb13b9900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 262687.000000, idle connection 77087.000000, request 304396.308422 06/18/2026 04:05:50.707 7fbdb13b9900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6379 06/18/2026 04:05:50.707 7fbdb13b9900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:50.707 7fbdb13b9900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6379 (604.0732860565186 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1677588942, topics=[]) 06/18/2026 04:05:50.708 7fbdb13b9900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1677588942 with 0 response partitions (1 implied) 06/18/2026 04:05:50.761 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 505 06/18/2026 04:05:50.762 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 06/18/2026 04:05:50.762 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 06/18/2026 04:05:50.762 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/18/2026 04:05:50.762 7fbdb13b95e0 [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=1098554015, session_epoch=6353, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:50.762 7fbdb13b95e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6365 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1098554015, session_epoch=6353, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:50.762 7fbdb13b95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 263278.551514, idle connection 202273.000000, request 304999.944210 06/18/2026 04:05:50.763 7fbdb13b95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 263277.755371, idle connection 202272.000000, request 304999.151707 06/18/2026 04:05:50.809 7fbdb13b94a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 265085.357178, idle connection 141981.000000, request 304399.045467 06/18/2026 04:05:50.810 7fbdb13b94a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6324 06/18/2026 04:05:50.810 7fbdb13b94a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:50.810 7fbdb13b94a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6324 (601.5293598175049 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=206808669, topics=[]) 06/18/2026 04:05:50.810 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 206808669 with 0 response partitions (1 implied) 06/18/2026 04:05:50.839 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258969.353271, idle connection 197783.000000, request 304398.943424 06/18/2026 04:05:50.839 7fbdaedf7720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9947 06/18/2026 04:05:50.839 7fbdaedf7720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:50.839 7fbdaedf7720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 9947 (601.6614437103271 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=464343197, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=53767, last_stable_offset=53767, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xd2\x06\x00\x00\x01\x04\x00\x00\x00\x00\x02\x9d\x90%\xf6\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/18/2026 04:05:50.840 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 464343197 with 1 response partitions (0 implied) 06/18/2026 04:05:50.840 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 53766 06/18/2026 04:05:50.840 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 53766 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 06/18/2026 04:05:50.840 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 53767 (leader epoch 0) 06/18/2026 04:05:50.941 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 53767 06/18/2026 04:05:50.941 7fbdaedf7720 [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/18/2026 04:05:50.941 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 06/18/2026 04:05:50.941 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:50.941 7fbdaedf7720 [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=464343197, session_epoch=9937, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=53767, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/18/2026 04:05:50.941 7fbdaedf7720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 9948 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=464343197, session_epoch=9937, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=53767, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/18/2026 04:05:50.942 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258866.403320, idle connection 197680.000000, request 304999.942303 06/18/2026 04:05:50.942 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258865.979492, idle connection 197679.000000, request 304999.527693 06/18/2026 04:05:51.038 7fbdb13b92c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 262789.924316, idle connection 440263.000000, request 304397.802830 06/18/2026 04:05:51.039 7fbdb13b92c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6786 06/18/2026 04:05:51.039 7fbdb13b92c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:51.039 7fbdb13b92c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6786 (602.84423828125 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1321523926, topics=[(topics='-uve-topic-23', partitions=[(partition=0, error_code=0, highwater_offset=4462, last_stable_offset=4462, log_start_offset=0, aborted_transactions=NULL, records=b"\x00\x00\x00\x00\x00\x00\x11l\x00\x00\x01\xeb\x00\x00\x00\x00\x02F\x9e'R\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\xb6\x03\x00\x00\x00\xf8\x02ObjectGeneratorInfo:cn-jenkins-d...")])]) 06/18/2026 04:05:51.039 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1321523926 with 1 response partitions (0 implied) 06/18/2026 04:05:51.039 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 503 bytes of data for partition TopicPartition(topic='-uve-topic-23', partition=0) with offset 4460 06/18/2026 04:05:51.039 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4460 for assigned partition TopicPartition(topic='-uve-topic-23', partition=0) 06/18/2026 04:05:51.040 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-23', partition=0) to 4462 (leader epoch 0) 06/18/2026 04:05:51.040 7fbdb01b2f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 263829.120361, idle connection 202824.000000, request 304396.951914 06/18/2026 04:05:51.040 7fbdb01b2f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6333 06/18/2026 04:05:51.040 7fbdb01b2f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:51.040 7fbdb01b2f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6333 (603.4038066864014 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1674122441, topics=[]) 06/18/2026 04:05:51.040 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1674122441 with 0 response partitions (1 implied) 06/18/2026 04:05:51.093 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 1898 06/18/2026 04:05:51.093 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 06/18/2026 04:05:51.093 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 06/18/2026 04:05:51.093 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/18/2026 04:05:51.093 7fbdaf3dd220 [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=515211984, session_epoch=6528, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:51.093 7fbdaf3dd220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6541 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=515211984, session_epoch=6528, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:51.094 7fbdaf3dd220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 264085.434082, idle connection 202769.000000, request 304999.945879 06/18/2026 04:05:51.094 7fbdaf3dd220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 264084.950928, idle connection 202768.000000, request 304999.469757 06/18/2026 04:05:51.094 7fbdb01b2e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 261666.633301, idle connection 198814.000000, request 304399.287224 06/18/2026 04:05:51.095 7fbdb01b2e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6528 06/18/2026 04:05:51.095 7fbdb01b2e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:51.095 7fbdb01b2e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6528 (601.2816429138184 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=683819233, topics=[]) 06/18/2026 04:05:51.095 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 683819233 with 0 response partitions (1 implied) 06/18/2026 04:05:51.140 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 4462 06/18/2026 04:05:51.140 7fbdb13b92c0 [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/18/2026 04:05:51.140 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered {TopicPartition(topic='-uve-topic-23', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 06/18/2026 04:05:51.140 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:51.141 7fbdb13b92c0 [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=1321523926, session_epoch=6773, topics=[(topic='-uve-topic-23', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4462, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/18/2026 04:05:51.141 7fbdb13b92c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6787 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1321523926, session_epoch=6773, topics=[(topic='-uve-topic-23', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4462, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/18/2026 04:05:51.141 7fbdb13b92c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 262687.151855, idle connection 440160.000000, request 304999.947309 06/18/2026 04:05:51.141 7fbdb13b92c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 262686.629639, idle connection 440160.000000, request 304999.433517 06/18/2026 04:05:51.189 7fbdb13b9860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 262686.710205, idle connection 201679.000000, request 304398.573875 06/18/2026 04:05:51.190 7fbdb13b9860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6352 06/18/2026 04:05:51.190 7fbdb13b9860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:51.190 7fbdb13b9860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6352 (602.1239757537842 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1380226864, topics=[]) 06/18/2026 04:05:51.190 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1380226864 with 0 response partitions (1 implied) 06/18/2026 04:05:51.201 7fbdb13b97c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 261058.492920, idle connection 438848.000000, request 304398.894310 06/18/2026 04:05:51.202 7fbdb13b97c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7118 06/18/2026 04:05:51.202 7fbdb13b97c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:51.202 7fbdb13b97c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7118 (601.656436920166 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2025868759, topics=[]) 06/18/2026 04:05:51.202 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2025868759 with 0 response partitions (1 implied) 06/18/2026 04:05:51.207 7fbdb13b99a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 265600.272217, idle connection 202843.000000, request 304397.462606 06/18/2026 04:05:51.208 7fbdb13b99a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6428 06/18/2026 04:05:51.208 7fbdb13b99a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:51.208 7fbdb13b99a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6428 (603.0306816101074 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2047323638, topics=[]) 06/18/2026 04:05:51.208 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2047323638 with 0 response partitions (1 implied) 06/18/2026 04:05:51.307 7fbdb01b2cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 170 06/18/2026 04:05:51.307 7fbdb01b2cc0 [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/18/2026 04:05:51.308 7fbdb01b2cc0 [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/18/2026 04:05:51.308 7fbdb01b2cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:51.308 7fbdb01b2cc0 [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=1059026835, session_epoch=6302, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:51.308 7fbdb01b2cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6321 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1059026835, session_epoch=6302, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:51.308 7fbdb01b2cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 262065.003418, idle connection 439457.000000, request 304999.947071 06/18/2026 04:05:51.308 7fbdb13b9900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 561 06/18/2026 04:05:51.308 7fbdb13b9900 [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/18/2026 04:05:51.308 7fbdb13b9900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 06/18/2026 04:05:51.309 7fbdb13b9900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/18/2026 04:05:51.309 7fbdb13b9900 [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=1677588942, session_epoch=6362, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:51.309 7fbdb13b9900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6380 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1677588942, session_epoch=6362, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:51.309 7fbdb13b9900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 262085.114746, idle connection 76485.000000, request 304999.962807 06/18/2026 04:05:51.309 7fbdb01b2cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 262063.859131, idle connection 439455.000000, request 304998.811245 06/18/2026 04:05:51.310 7fbdb13b9900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 262084.354980, idle connection 76484.000000, request 304999.207258 06/18/2026 04:05:51.364 7fbdb13b95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 262677.061768, idle connection 201672.000000, request 304398.455143 06/18/2026 04:05:51.364 7fbdb13b95e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6365 06/18/2026 04:05:51.364 7fbdb13b95e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:51.365 7fbdb13b95e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6365 (602.1053791046143 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1098554015, topics=[]) 06/18/2026 04:05:51.365 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1098554015 with 0 response partitions (1 implied) 06/18/2026 04:05:51.411 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 370 06/18/2026 04:05:51.411 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 06/18/2026 04:05:51.411 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 06/18/2026 04:05:51.411 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/18/2026 04:05:51.411 7fbdb13b94a0 [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=206808669, session_epoch=6314, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:51.411 7fbdb13b94a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6325 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=206808669, session_epoch=6314, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:51.411 7fbdb13b94a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 264483.365234, idle connection 141379.000000, request 304999.936342 06/18/2026 04:05:51.412 7fbdb13b94a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 264482.893555, idle connection 141378.000000, request 304999.475241 06/18/2026 04:05:51.543 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258265.485596, idle connection 197079.000000, request 304399.026155 06/18/2026 04:05:51.543 7fbdaedf7720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9948 06/18/2026 04:05:51.543 7fbdaedf7720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:51.543 7fbdaedf7720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 9948 (601.531982421875 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=464343197, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=53769, last_stable_offset=53769, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xd2\x07\x00\x00\x01\x19\x00\x00\x00\x00\x02%\x05\\\x11\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\xcc\x03\x00\x00\x00\x8e\x03ObjectConfigDatabaseInfo:cn-jenk...')])]) 06/18/2026 04:05:51.543 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 464343197 with 1 response partitions (0 implied) 06/18/2026 04:05:51.544 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 565 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 53767 06/18/2026 04:05:51.544 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 53767 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 06/18/2026 04:05:51.544 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 53769 (leader epoch 0) 06/18/2026 04:05:51.641 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 255 06/18/2026 04:05:51.642 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 06/18/2026 04:05:51.642 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 06/18/2026 04:05:51.642 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/18/2026 04:05:51.642 7fbdb01b2f40 [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=1674122441, session_epoch=6316, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:51.642 7fbdb01b2f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6334 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1674122441, session_epoch=6316, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:51.642 7fbdb01b2f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 263226.828613, idle connection 202222.000000, request 304999.947309 06/18/2026 04:05:51.643 7fbdb01b2f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 263226.427734, idle connection 202222.000000, request 304999.552250 06/18/2026 04:05:51.644 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 53769 06/18/2026 04:05:51.644 7fbdaedf7720 [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/18/2026 04:05:51.645 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 06/18/2026 04:05:51.645 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:51.645 7fbdaedf7720 [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=464343197, session_epoch=9938, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=53769, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/18/2026 04:05:51.645 7fbdaedf7720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 9949 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=464343197, session_epoch=9938, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=53769, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/18/2026 04:05:51.645 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258163.038818, idle connection 196976.000000, request 304999.956369 06/18/2026 04:05:51.645 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258162.654785, idle connection 196976.000000, request 304999.575615 06/18/2026 04:05:51.695 7fbdaf3dd220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 263484.167480, idle connection 202167.000000, request 304398.679733 06/18/2026 04:05:51.695 7fbdaf3dd220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6541 06/18/2026 04:05:51.696 7fbdaf3dd220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:51.696 7fbdaf3dd220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6541 (602.0805835723877 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=515211984, topics=[]) 06/18/2026 04:05:51.696 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 515211984 with 0 response partitions (1 implied) 06/18/2026 04:05:51.696 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 1340 06/18/2026 04:05:51.696 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 06/18/2026 04:05:51.696 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)]) 06/18/2026 04:05:51.696 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:51.696 7fbdb01b2e00 [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=683819233, session_epoch=6506, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:51.697 7fbdb01b2e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6529 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=683819233, session_epoch=6506, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:51.697 7fbdb01b2e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 261064.239258, idle connection 198212.000000, request 304999.953985 06/18/2026 04:05:51.697 7fbdb01b2e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 261063.750244, idle connection 198212.000000, request 304999.469995 06/18/2026 04:05:51.742 7fbdb13b92c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 262085.877197, idle connection 439559.000000, request 304398.667097 06/18/2026 04:05:51.743 7fbdb13b92c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6787 06/18/2026 04:05:51.743 7fbdb13b92c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:51.743 7fbdb13b92c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6787 (602.1101474761963 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1321523926, topics=[]) 06/18/2026 04:05:51.743 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1321523926 with 0 response partitions (1 implied) 06/18/2026 04:05:51.791 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 425 06/18/2026 04:05:51.791 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 06/18/2026 04:05:51.791 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 06/18/2026 04:05:51.791 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/18/2026 04:05:51.791 7fbdb13b9860 [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=1380226864, session_epoch=6343, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:51.792 7fbdb13b9860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6353 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1380226864, session_epoch=6343, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:51.792 7fbdb13b9860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 262084.189209, idle connection 201076.000000, request 304999.924183 06/18/2026 04:05:51.792 7fbdb13b9860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 262083.680664, idle connection 201076.000000, request 304999.428272 06/18/2026 04:05:51.802 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 4877 06/18/2026 04:05:51.802 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 06/18/2026 04:05:51.803 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 06/18/2026 04:05:51.803 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/18/2026 04:05:51.803 7fbdb13b97c0 [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=2025868759, session_epoch=7099, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:51.803 7fbdb13b97c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7119 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2025868759, session_epoch=7099, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:51.803 7fbdb13b97c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260456.732910, idle connection 438246.000000, request 304999.950647 06/18/2026 04:05:51.803 7fbdb13b97c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260456.362549, idle connection 438245.000000, request 304999.586582 06/18/2026 04:05:51.809 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 654 06/18/2026 04:05:51.809 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 06/18/2026 04:05:51.809 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 06/18/2026 04:05:51.810 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/18/2026 04:05:51.810 7fbdb13b99a0 [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=2047323638, session_epoch=6415, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:51.810 7fbdb13b99a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6429 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2047323638, session_epoch=6415, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:51.810 7fbdb13b99a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 264997.394775, idle connection 202240.000000, request 304999.936581 06/18/2026 04:05:51.811 7fbdb13b99a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 264996.906738, idle connection 202239.000000, request 304999.455214 06/18/2026 04:05:51.910 7fbdb01b2cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 261462.995850, idle connection 438855.000000, request 304397.938490 06/18/2026 04:05:51.911 7fbdb01b2cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6321 06/18/2026 04:05:51.911 7fbdb01b2cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:51.911 7fbdb01b2cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6321 (602.6432514190674 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1059026835, topics=[]) 06/18/2026 04:05:51.911 7fbdb01b2cc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1059026835 with 0 response partitions (1 implied) 06/18/2026 04:05:51.911 7fbdb13b9900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 261482.828125, idle connection 75883.000000, request 304397.675753 06/18/2026 04:05:51.911 7fbdb13b9900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6380 06/18/2026 04:05:51.912 7fbdb13b9900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:51.912 7fbdb13b9900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6380 (602.811336517334 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1677588942, topics=[]) 06/18/2026 04:05:51.912 7fbdb13b9900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1677588942 with 0 response partitions (1 implied) 06/18/2026 04:05:51.965 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 505 06/18/2026 04:05:51.965 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 06/18/2026 04:05:51.965 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 06/18/2026 04:05:51.966 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/18/2026 04:05:51.966 7fbdb13b95e0 [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=1098554015, session_epoch=6354, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:51.966 7fbdb13b95e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6366 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1098554015, session_epoch=6354, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:51.966 7fbdb13b95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 262075.042725, idle connection 201070.000000, request 304999.927282 06/18/2026 04:05:51.966 7fbdb13b95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 262074.530762, idle connection 201069.000000, request 304999.429464 06/18/2026 04:05:52.012 7fbdb13b94a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 263882.404297, idle connection 140778.000000, request 304398.983240 06/18/2026 04:05:52.013 7fbdb13b94a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6325 06/18/2026 04:05:52.013 7fbdb13b94a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:52.013 7fbdb13b94a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6325 (601.5331745147705 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=206808669, topics=[]) 06/18/2026 04:05:52.013 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 206808669 with 0 response partitions (1 implied) 06/18/2026 04:05:52.244 7fbdb01b2f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 262625.038086, idle connection 201620.000000, request 304398.154736 06/18/2026 04:05:52.246 7fbdb01b2f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6334 06/18/2026 04:05:52.246 7fbdb01b2f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:52.246 7fbdb01b2f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6334 (604.1903495788574 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1674122441, topics=[]) 06/18/2026 04:05:52.247 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1674122441 with 0 response partitions (1 implied) 06/18/2026 04:05:52.248 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257560.450684, idle connection 196374.000000, request 304397.365332 06/18/2026 04:05:52.248 7fbdaedf7720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9949 06/18/2026 04:05:52.248 7fbdaedf7720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:52.248 7fbdaedf7720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 9949 (603.0788421630859 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=464343197, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=53771, last_stable_offset=53771, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xd2\t\x00\x00\x01\x04\x00\x00\x00\x00\x02y\xe1\xbc\xe8\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/18/2026 04:05:52.248 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 464343197 with 1 response partitions (0 implied) 06/18/2026 04:05:52.248 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 539 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 53769 06/18/2026 04:05:52.249 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 53769 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 06/18/2026 04:05:52.249 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 53771 (leader epoch 0) 06/18/2026 04:05:52.296 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 1898 06/18/2026 04:05:52.296 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 06/18/2026 04:05:52.297 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 06/18/2026 04:05:52.297 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/18/2026 04:05:52.297 7fbdaf3dd220 [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=515211984, session_epoch=6529, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:52.297 7fbdaf3dd220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6542 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=515211984, session_epoch=6529, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:52.297 7fbdaf3dd220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 262881.924561, idle connection 201565.000000, request 304999.946117 06/18/2026 04:05:52.298 7fbdaf3dd220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 262881.483887, idle connection 201565.000000, request 304999.513865 06/18/2026 04:05:52.298 7fbdb01b2e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260463.179199, idle connection 197611.000000, request 304398.895741 06/18/2026 04:05:52.298 7fbdb01b2e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6529 06/18/2026 04:05:52.298 7fbdb01b2e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:52.298 7fbdb01b2e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6529 (601.7224788665771 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=683819233, topics=[]) 06/18/2026 04:05:52.299 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 683819233 with 0 response partitions (1 implied) 06/18/2026 04:05:52.344 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 4462 06/18/2026 04:05:52.344 7fbdb13b92c0 [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/18/2026 04:05:52.344 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 06/18/2026 04:05:52.344 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:52.344 7fbdb13b92c0 [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=1321523926, session_epoch=6774, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:52.345 7fbdb13b92c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6788 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1321523926, session_epoch=6774, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:52.345 7fbdb13b92c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 261483.294189, idle connection 438957.000000, request 304999.945402 06/18/2026 04:05:52.345 7fbdb13b92c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 261482.891602, idle connection 438956.000000, request 304999.551535 06/18/2026 04:05:52.349 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 53771 06/18/2026 04:05:52.350 7fbdaedf7720 [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/18/2026 04:05:52.350 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 06/18/2026 04:05:52.350 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:52.350 7fbdaedf7720 [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=464343197, session_epoch=9939, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=53771, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/18/2026 04:05:52.350 7fbdaedf7720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 9950 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=464343197, session_epoch=9939, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=53771, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/18/2026 04:05:52.350 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257457.937988, idle connection 196271.000000, request 304999.957323 06/18/2026 04:05:52.351 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257457.362305, idle connection 196271.000000, request 304999.385118 06/18/2026 04:05:52.393 7fbdb13b9860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 261483.178955, idle connection 200475.000000, request 304398.920774 06/18/2026 04:05:52.393 7fbdb13b9860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6353 06/18/2026 04:05:52.393 7fbdb13b9860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:52.393 7fbdb13b9860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6353 (601.5770435333252 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1380226864, topics=[]) 06/18/2026 04:05:52.394 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1380226864 with 0 response partitions (1 implied) 06/18/2026 04:05:52.404 7fbdb13b97c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259855.786621, idle connection 437645.000000, request 304399.003506 06/18/2026 04:05:52.404 7fbdb13b97c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7119 06/18/2026 04:05:52.404 7fbdb13b97c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:52.404 7fbdb13b97c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7119 (601.4902591705322 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2025868759, topics=[]) 06/18/2026 04:05:52.405 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2025868759 with 0 response partitions (1 implied) 06/18/2026 04:05:52.412 7fbdb13b99a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 264395.873535, idle connection 201638.000000, request 304398.418188 06/18/2026 04:05:52.412 7fbdb13b99a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6429 06/18/2026 04:05:52.412 7fbdb13b99a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:52.412 7fbdb13b99a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6429 (602.1597385406494 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2047323638, topics=[]) 06/18/2026 04:05:52.412 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2047323638 with 0 response partitions (1 implied) 06/18/2026 04:05:52.511 7fbdb01b2cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 170 06/18/2026 04:05:52.512 7fbdb01b2cc0 [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/18/2026 04:05:52.512 7fbdb01b2cc0 [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/18/2026 04:05:52.512 7fbdb01b2cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:52.512 7fbdb01b2cc0 [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=1059026835, session_epoch=6303, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:52.512 7fbdb01b2cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6322 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1059026835, session_epoch=6303, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:52.512 7fbdb01b2cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260861.083984, idle connection 438253.000000, request 304999.948263 06/18/2026 04:05:52.512 7fbdb13b9900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 561 06/18/2026 04:05:52.512 7fbdb13b9900 [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/18/2026 04:05:52.512 7fbdb13b9900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 06/18/2026 04:05:52.513 7fbdb13b9900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/18/2026 04:05:52.513 7fbdb13b9900 [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=1677588942, session_epoch=6363, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:52.513 7fbdb13b9900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6381 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1677588942, session_epoch=6363, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:52.513 7fbdb13b9900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260881.142822, idle connection 75281.000000, request 304999.949932 06/18/2026 04:05:52.513 7fbdb01b2cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260859.842529, idle connection 438251.000000, request 304998.714209 06/18/2026 04:05:52.514 7fbdb13b9900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260880.209473, idle connection 75280.000000, request 304999.024630 06/18/2026 04:05:52.567 7fbdb13b95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 261474.005371, idle connection 200469.000000, request 304398.896456 06/18/2026 04:05:52.567 7fbdb13b95e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6366 06/18/2026 04:05:52.567 7fbdb13b95e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:52.568 7fbdb13b95e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6366 (601.649284362793 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1098554015, topics=[]) 06/18/2026 04:05:52.568 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1098554015 with 0 response partitions (1 implied) 06/18/2026 04:05:52.613 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 370 06/18/2026 04:05:52.614 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 06/18/2026 04:05:52.614 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 06/18/2026 04:05:52.614 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/18/2026 04:05:52.614 7fbdb13b94a0 [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=206808669, session_epoch=6315, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:52.614 7fbdb13b94a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6326 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=206808669, session_epoch=6315, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:52.614 7fbdb13b94a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 263280.386719, idle connection 140176.000000, request 304999.945402 06/18/2026 04:05:52.615 7fbdb13b94a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 263279.822266, idle connection 140175.000000, request 304999.388695 06/18/2026 04:05:52.848 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 255 06/18/2026 04:05:52.848 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 06/18/2026 04:05:52.848 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 06/18/2026 04:05:52.848 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/18/2026 04:05:52.848 7fbdb01b2f40 [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=1674122441, session_epoch=6317, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:52.848 7fbdb01b2f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6335 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1674122441, session_epoch=6317, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:52.848 7fbdb01b2f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 262020.444580, idle connection 201016.000000, request 304999.946833 06/18/2026 04:05:52.849 7fbdb01b2f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 262020.023438, idle connection 201015.000000, request 304999.533415 06/18/2026 04:05:52.898 7fbdaf3dd220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 262280.638184, idle connection 200964.000000, request 304398.659706 06/18/2026 04:05:52.899 7fbdaf3dd220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6542 06/18/2026 04:05:52.899 7fbdaf3dd220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:52.899 7fbdaf3dd220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6542 (601.8679141998291 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=515211984, topics=[]) 06/18/2026 04:05:52.899 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 515211984 with 0 response partitions (1 implied) 06/18/2026 04:05:52.899 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 1340 06/18/2026 04:05:52.899 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 06/18/2026 04:05:52.899 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)]) 06/18/2026 04:05:52.900 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:52.900 7fbdb01b2e00 [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=683819233, session_epoch=6507, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:52.900 7fbdb01b2e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6530 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=683819233, session_epoch=6507, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:52.900 7fbdb01b2e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259861.108154, idle connection 197009.000000, request 304999.956608 06/18/2026 04:05:52.900 7fbdb01b2e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259860.757324, idle connection 197009.000000, request 304999.608517 06/18/2026 04:05:52.946 7fbdb13b92c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260882.160645, idle connection 438355.000000, request 304398.812294 06/18/2026 04:05:52.946 7fbdb13b92c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6788 06/18/2026 04:05:52.947 7fbdb13b92c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:52.947 7fbdb13b92c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6788 (601.942777633667 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1321523926, topics=[]) 06/18/2026 04:05:52.947 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1321523926 with 0 response partitions (1 implied) 06/18/2026 04:05:52.951 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256856.770996, idle connection 195670.000000, request 304398.721933 06/18/2026 04:05:52.952 7fbdaedf7720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9950 06/18/2026 04:05:52.953 7fbdaedf7720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:52.953 7fbdaedf7720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 9950 (602.7591228485107 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=464343197, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=53773, last_stable_offset=53773, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xd2\x0b\x00\x00\x01\x19\x00\x00\x00\x00\x02[:\x7f\x82\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\xcc\x03\x00\x00\x00\x8e\x03ObjectConfigDatabaseInfo:cn-jenk...')])]) 06/18/2026 04:05:52.953 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 464343197 with 1 response partitions (0 implied) 06/18/2026 04:05:52.953 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 560 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 53771 06/18/2026 04:05:52.954 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 53771 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 06/18/2026 04:05:52.954 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 53773 (leader epoch 0) 06/18/2026 04:05:52.994 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 425 06/18/2026 04:05:52.995 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 06/18/2026 04:05:52.995 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 06/18/2026 04:05:52.995 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/18/2026 04:05:52.995 7fbdb13b9860 [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=1380226864, session_epoch=6344, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:52.995 7fbdb13b9860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6354 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1380226864, session_epoch=6344, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:52.995 7fbdb13b9860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260880.607422, idle connection 199872.000000, request 304999.927521 06/18/2026 04:05:52.996 7fbdb13b9860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260879.903076, idle connection 199872.000000, request 304999.233007 06/18/2026 04:05:53.007 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 4877 06/18/2026 04:05:53.007 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 06/18/2026 04:05:53.007 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 06/18/2026 04:05:53.007 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/18/2026 04:05:53.007 7fbdb13b97c0 [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=2025868759, session_epoch=7100, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:53.007 7fbdb13b97c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7120 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2025868759, session_epoch=7100, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:53.008 7fbdb13b97c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259252.226318, idle connection 437041.000000, request 304999.946594 06/18/2026 04:05:53.008 7fbdb13b97c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259251.760986, idle connection 437041.000000, request 304999.488831 06/18/2026 04:05:53.014 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 654 06/18/2026 04:05:53.014 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 06/18/2026 04:05:53.014 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 06/18/2026 04:05:53.014 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/18/2026 04:05:53.014 7fbdb13b99a0 [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=2047323638, session_epoch=6416, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:53.014 7fbdb13b99a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6430 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2047323638, session_epoch=6416, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:53.015 7fbdb13b99a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 263792.921387, idle connection 201035.000000, request 304999.947786 06/18/2026 04:05:53.015 7fbdb13b99a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 263792.532227, idle connection 201035.000000, request 304999.565363 06/18/2026 04:05:53.055 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 53773 06/18/2026 04:05:53.056 7fbdaedf7720 [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/18/2026 04:05:53.056 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 06/18/2026 04:05:53.056 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:53.056 7fbdaedf7720 [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=464343197, session_epoch=9940, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=53773, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/18/2026 04:05:53.057 7fbdaedf7720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 9951 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=464343197, session_epoch=9940, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=53773, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/18/2026 04:05:53.057 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256751.371582, idle connection 195565.000000, request 304999.943018 06/18/2026 04:05:53.057 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256750.961914, idle connection 195564.000000, request 304999.542236 06/18/2026 04:05:53.117 7fbdb01b2cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260256.344971, idle connection 437648.000000, request 304395.206928 06/18/2026 04:05:53.117 7fbdb13b9900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260276.560547, idle connection 74676.000000, request 304395.370245 06/18/2026 04:05:53.118 7fbdb01b2cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6322 06/18/2026 04:05:53.118 7fbdb01b2cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:53.119 7fbdb01b2cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6322 (606.4555644989014 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1059026835, topics=[]) 06/18/2026 04:05:53.119 7fbdb01b2cc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1059026835 with 0 response partitions (1 implied) 06/18/2026 04:05:53.119 7fbdb13b9900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6381 06/18/2026 04:05:53.119 7fbdb13b9900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:53.119 7fbdb13b9900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6381 (606.6064834594727 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1677588942, topics=[]) 06/18/2026 04:05:53.120 7fbdb13b9900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1677588942 with 0 response partitions (1 implied) 06/18/2026 04:05:53.168 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 505 06/18/2026 04:05:53.168 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 06/18/2026 04:05:53.168 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 06/18/2026 04:05:53.169 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/18/2026 04:05:53.169 7fbdb13b95e0 [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=1098554015, session_epoch=6355, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:53.169 7fbdb13b95e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6367 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1098554015, session_epoch=6355, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:53.169 7fbdb13b95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260871.936279, idle connection 199867.000000, request 304999.946833 06/18/2026 04:05:53.169 7fbdb13b95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260871.494873, idle connection 199866.000000, request 304999.513149 06/18/2026 04:05:53.216 7fbdb13b94a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 262679.123779, idle connection 139574.000000, request 304398.683310 06/18/2026 04:05:53.216 7fbdb13b94a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6326 06/18/2026 04:05:53.216 7fbdb13b94a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:53.216 7fbdb13b94a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6326 (601.8490791320801 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=206808669, topics=[]) 06/18/2026 04:05:53.216 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 206808669 with 0 response partitions (1 implied) 06/18/2026 04:05:53.449 7fbdb01b2f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 261419.483398, idle connection 200415.000000, request 304398.984432 06/18/2026 04:05:53.450 7fbdb01b2f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6335 06/18/2026 04:05:53.450 7fbdb01b2f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:53.450 7fbdb01b2f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6335 (601.719856262207 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1674122441, topics=[]) 06/18/2026 04:05:53.450 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1674122441 with 0 response partitions (1 implied) 06/18/2026 04:05:53.500 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 1898 06/18/2026 04:05:53.500 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 06/18/2026 04:05:53.500 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 06/18/2026 04:05:53.500 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/18/2026 04:05:53.500 7fbdaf3dd220 [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=515211984, session_epoch=6530, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:53.500 7fbdaf3dd220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6543 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=515211984, session_epoch=6530, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:53.500 7fbdaf3dd220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 261678.624023, idle connection 200362.000000, request 304999.945641 06/18/2026 04:05:53.501 7fbdaf3dd220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 261678.219727, idle connection 200361.000000, request 304999.550343 06/18/2026 04:05:53.501 7fbdb01b2e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259259.874512, idle connection 196408.000000, request 304398.723841 06/18/2026 04:05:53.501 7fbdb01b2e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6530 06/18/2026 04:05:53.501 7fbdb01b2e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:53.502 7fbdb01b2e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6530 (601.7813682556152 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=683819233, topics=[]) 06/18/2026 04:05:53.502 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 683819233 with 0 response partitions (1 implied) 06/18/2026 04:05:53.547 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 4462 06/18/2026 04:05:53.548 7fbdb13b92c0 [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/18/2026 04:05:53.548 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 06/18/2026 04:05:53.548 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:53.548 7fbdb13b92c0 [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=1321523926, session_epoch=6775, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:53.548 7fbdb13b92c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6789 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1321523926, session_epoch=6775, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:53.548 7fbdb13b92c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260279.707275, idle connection 437753.000000, request 304999.944687 06/18/2026 04:05:53.549 7fbdb13b92c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260279.247803, idle connection 437752.000000, request 304999.490976 06/18/2026 04:05:53.597 7fbdb13b9860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260279.237549, idle connection 199271.000000, request 304398.555994 06/18/2026 04:05:53.597 7fbdb13b9860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6354 06/18/2026 04:05:53.597 7fbdb13b9860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:53.597 7fbdb13b9860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6354 (601.9876003265381 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1380226864, topics=[]) 06/18/2026 04:05:53.598 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1380226864 with 0 response partitions (1 implied) 06/18/2026 04:05:53.609 7fbdb13b97c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258651.198242, idle connection 436440.000000, request 304398.910046 06/18/2026 04:05:53.609 7fbdb13b97c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7120 06/18/2026 04:05:53.609 7fbdb13b97c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:53.609 7fbdb13b97c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7120 (601.6614437103271 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2025868759, topics=[]) 06/18/2026 04:05:53.609 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2025868759 with 0 response partitions (1 implied) 06/18/2026 04:05:53.618 7fbdb13b99a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 263189.556641, idle connection 200432.000000, request 304396.576643 06/18/2026 04:05:53.618 7fbdb13b99a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6430 06/18/2026 04:05:53.618 7fbdb13b99a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:53.619 7fbdb13b99a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6430 (604.001522064209 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2047323638, topics=[]) 06/18/2026 04:05:53.619 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2047323638 with 0 response partitions (1 implied) 06/18/2026 04:05:53.658 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256150.468994, idle connection 194964.000000, request 304399.042130 06/18/2026 04:05:53.658 7fbdaedf7720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9951 06/18/2026 04:05:53.658 7fbdaedf7720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:53.658 7fbdaedf7720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 9951 (601.5489101409912 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=464343197, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=53774, last_stable_offset=53774, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xd2\r\x00\x00\x01\x19\x00\x00\x00\x00\x02\xb7n\xf9,\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\xcc\x03\x00\x00\x00\x8e\x03ObjectConfigDatabaseInfo:cn-jenk...')])]) 06/18/2026 04:05:53.658 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 464343197 with 1 response partitions (0 implied) 06/18/2026 04:05:53.659 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 293 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 53773 06/18/2026 04:05:53.659 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 53773 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 06/18/2026 04:05:53.659 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 53774 (leader epoch 0) 06/18/2026 04:05:53.719 7fbdb01b2cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 170 06/18/2026 04:05:53.719 7fbdb01b2cc0 [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/18/2026 04:05:53.719 7fbdb01b2cc0 [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/18/2026 04:05:53.720 7fbdb01b2cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:53.720 7fbdb01b2cc0 [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=1059026835, session_epoch=6304, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:53.720 7fbdb01b2cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6323 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1059026835, session_epoch=6304, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:53.720 7fbdb01b2cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259653.204590, idle connection 437045.000000, request 304999.948263 06/18/2026 04:05:53.720 7fbdb13b9900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 561 06/18/2026 04:05:53.720 7fbdb13b9900 [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/18/2026 04:05:53.720 7fbdb13b9900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 06/18/2026 04:05:53.720 7fbdb13b9900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/18/2026 04:05:53.720 7fbdb13b9900 [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=1677588942, session_epoch=6364, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:53.721 7fbdb13b9900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6382 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1677588942, session_epoch=6364, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:53.721 7fbdb13b9900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259673.259033, idle connection 74073.000000, request 304999.951839 06/18/2026 04:05:53.721 7fbdb01b2cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259652.107422, idle connection 437044.000000, request 304998.861074 06/18/2026 04:05:53.721 7fbdb13b9900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259672.498779, idle connection 74072.000000, request 304999.196053 06/18/2026 04:05:53.760 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 53774 06/18/2026 04:05:53.760 7fbdaedf7720 [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/18/2026 04:05:53.760 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 06/18/2026 04:05:53.760 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:53.760 7fbdaedf7720 [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=464343197, session_epoch=9941, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=53774, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/18/2026 04:05:53.760 7fbdaedf7720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 9952 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=464343197, session_epoch=9941, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=53774, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/18/2026 04:05:53.760 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256047.863037, idle connection 194861.000000, request 304999.949455 06/18/2026 04:05:53.761 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256047.435547, idle connection 194861.000000, request 304999.525309 06/18/2026 04:05:53.770 7fbdb13b95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260270.947998, idle connection 199266.000000, request 304398.959875 06/18/2026 04:05:53.770 7fbdb13b95e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6367 06/18/2026 04:05:53.770 7fbdb13b95e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:53.771 7fbdb13b95e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6367 (601.5725135803223 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1098554015, topics=[]) 06/18/2026 04:05:53.771 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1098554015 with 0 response partitions (1 implied) 06/18/2026 04:05:53.818 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 370 06/18/2026 04:05:53.818 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 06/18/2026 04:05:53.818 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 06/18/2026 04:05:53.819 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/18/2026 04:05:53.819 7fbdb13b94a0 [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=206808669, session_epoch=6316, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:53.819 7fbdb13b94a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6327 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=206808669, session_epoch=6316, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:53.819 7fbdb13b94a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 262075.745605, idle connection 138971.000000, request 304999.933958 06/18/2026 04:05:53.819 7fbdb13b94a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 262075.276855, idle connection 138971.000000, request 304999.474049 06/18/2026 04:05:54.051 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 255 06/18/2026 04:05:54.051 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 06/18/2026 04:05:54.051 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 06/18/2026 04:05:54.051 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/18/2026 04:05:54.051 7fbdb01b2f40 [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=1674122441, session_epoch=6318, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:54.052 7fbdb01b2f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6336 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1674122441, session_epoch=6318, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:54.052 7fbdb01b2f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260817.222656, idle connection 199812.000000, request 304999.946594 06/18/2026 04:05:54.052 7fbdb01b2f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260816.793945, idle connection 199812.000000, request 304999.526262 06/18/2026 04:05:54.102 7fbdaf3dd220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 261077.411377, idle connection 199761.000000, request 304398.730993 06/18/2026 04:05:54.102 7fbdaf3dd220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6543 06/18/2026 04:05:54.102 7fbdaf3dd220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:54.102 7fbdaf3dd220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6543 (602.0002365112305 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=515211984, topics=[]) 06/18/2026 04:05:54.103 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 515211984 with 0 response partitions (1 implied) 06/18/2026 04:05:54.103 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 1340 06/18/2026 04:05:54.103 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 06/18/2026 04:05:54.103 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)]) 06/18/2026 04:05:54.103 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:54.103 7fbdb01b2e00 [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=683819233, session_epoch=6508, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:54.104 7fbdb01b2e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6531 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=683819233, session_epoch=6508, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:54.104 7fbdb01b2e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258657.225830, idle connection 195805.000000, request 304999.938250 06/18/2026 04:05:54.104 7fbdb01b2e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258656.761963, idle connection 195805.000000, request 304999.481201 06/18/2026 04:05:54.149 7fbdb13b92c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259678.678223, idle connection 437152.000000, request 304398.916245 06/18/2026 04:05:54.150 7fbdb13b92c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6789 06/18/2026 04:05:54.150 7fbdb13b92c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:54.150 7fbdb13b92c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6789 (601.6740798950195 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1321523926, topics=[]) 06/18/2026 04:05:54.150 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1321523926 with 0 response partitions (1 implied) 06/18/2026 04:05:54.198 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 425 06/18/2026 04:05:54.198 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 06/18/2026 04:05:54.198 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 06/18/2026 04:05:54.198 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/18/2026 04:05:54.199 7fbdb13b9860 [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=1380226864, session_epoch=6345, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:54.199 7fbdb13b9860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6355 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1380226864, session_epoch=6345, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:54.199 7fbdb13b9860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259677.156250, idle connection 198669.000000, request 304999.946356 06/18/2026 04:05:54.199 7fbdb13b9860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259676.629883, idle connection 198669.000000, request 304999.427795 06/18/2026 04:05:54.210 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 4877 06/18/2026 04:05:54.210 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 06/18/2026 04:05:54.210 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 06/18/2026 04:05:54.210 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/18/2026 04:05:54.210 7fbdb13b97c0 [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=2025868759, session_epoch=7101, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:54.210 7fbdb13b97c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7121 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2025868759, session_epoch=7101, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:54.210 7fbdb13b97c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258049.356934, idle connection 435838.000000, request 304999.936819 06/18/2026 04:05:54.211 7fbdb13b97c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258048.684082, idle connection 435838.000000, request 304999.272823 06/18/2026 04:05:54.219 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 654 06/18/2026 04:05:54.220 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 06/18/2026 04:05:54.220 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 06/18/2026 04:05:54.220 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/18/2026 04:05:54.220 7fbdb13b99a0 [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=2047323638, session_epoch=6417, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:54.220 7fbdb13b99a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6431 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2047323638, session_epoch=6417, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:54.220 7fbdb13b99a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 262587.271484, idle connection 199830.000000, request 304999.947309 06/18/2026 04:05:54.221 7fbdb13b99a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 262586.332031, idle connection 199829.000000, request 304999.012232 06/18/2026 04:05:54.322 7fbdb01b2cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259051.248047, idle connection 436443.000000, request 304397.994041 06/18/2026 04:05:54.322 7fbdb01b2cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6323 06/18/2026 04:05:54.322 7fbdb01b2cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:54.323 7fbdb01b2cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6323 (602.569580078125 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1059026835, topics=[]) 06/18/2026 04:05:54.323 7fbdb01b2cc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1059026835 with 0 response partitions (1 implied) 06/18/2026 04:05:54.323 7fbdb13b9900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259071.106445, idle connection 73471.000000, request 304397.801399 06/18/2026 04:05:54.323 7fbdb13b9900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6382 06/18/2026 04:05:54.323 7fbdb13b9900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:54.323 7fbdb13b9900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6382 (602.5269031524658 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1677588942, topics=[]) 06/18/2026 04:05:54.323 7fbdb13b9900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1677588942 with 0 response partitions (1 implied) 06/18/2026 04:05:54.361 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255446.905762, idle connection 194260.000000, request 304398.992062 06/18/2026 04:05:54.362 7fbdaedf7720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9952 06/18/2026 04:05:54.362 7fbdaedf7720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:54.362 7fbdaedf7720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 9952 (601.5989780426025 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=464343197, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=53776, last_stable_offset=53776, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xd2\x0e\x00\x00\x01\x04\x00\x00\x00\x00\x02\x9e\x97\xd8\xb9\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 06/18/2026 04:05:54.362 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 464343197 with 1 response partitions (0 implied) 06/18/2026 04:05:54.362 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 539 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 53774 06/18/2026 04:05:54.362 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 53774 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 06/18/2026 04:05:54.363 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 53776 (leader epoch 0) 06/18/2026 04:05:54.371 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 505 06/18/2026 04:05:54.372 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 06/18/2026 04:05:54.372 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 06/18/2026 04:05:54.372 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/18/2026 04:05:54.372 7fbdb13b95e0 [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=1098554015, session_epoch=6356, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:54.372 7fbdb13b95e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6368 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1098554015, session_epoch=6356, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:54.372 7fbdb13b95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259668.905518, idle connection 198664.000000, request 304999.948025 06/18/2026 04:05:54.373 7fbdb13b95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259668.357910, idle connection 198663.000000, request 304999.407768 06/18/2026 04:05:54.420 7fbdb13b94a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 261474.701172, idle connection 138370.000000, request 304398.892164 06/18/2026 04:05:54.421 7fbdb13b94a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6327 06/18/2026 04:05:54.421 7fbdb13b94a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:54.421 7fbdb13b94a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6327 (602.1630764007568 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=206808669, topics=[]) 06/18/2026 04:05:54.421 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 206808669 with 0 response partitions (1 implied) 06/18/2026 04:05:54.464 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 53776 06/18/2026 04:05:54.464 7fbdaedf7720 [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/18/2026 04:05:54.464 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 06/18/2026 04:05:54.464 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:54.464 7fbdaedf7720 [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=464343197, session_epoch=9942, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=53776, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/18/2026 04:05:54.464 7fbdaedf7720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 9953 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=464343197, session_epoch=9942, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=53776, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/18/2026 04:05:54.465 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255343.462646, idle connection 194157.000000, request 304999.941826 06/18/2026 04:05:54.465 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255342.982666, idle connection 194156.000000, request 304999.471426 06/18/2026 04:05:54.653 7fbdb01b2f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260216.076172, idle connection 199211.000000, request 304398.799658 06/18/2026 04:05:54.653 7fbdb01b2f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6336 06/18/2026 04:05:54.653 7fbdb01b2f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:54.653 7fbdb01b2f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6336 (601.7546653747559 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1674122441, topics=[]) 06/18/2026 04:05:54.654 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1674122441 with 0 response partitions (1 implied) 06/18/2026 04:05:54.703 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 1898 06/18/2026 04:05:54.703 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 06/18/2026 04:05:54.703 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 06/18/2026 04:05:54.704 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/18/2026 04:05:54.704 7fbdaf3dd220 [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=515211984, session_epoch=6531, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:54.704 7fbdaf3dd220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6544 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=515211984, session_epoch=6531, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:54.704 7fbdaf3dd220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260474.927246, idle connection 199158.000000, request 304999.929905 06/18/2026 04:05:54.705 7fbdaf3dd220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260474.390137, idle connection 199158.000000, request 304999.400854 06/18/2026 04:05:54.705 7fbdb01b2e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258056.013916, idle connection 195204.000000, request 304398.732424 06/18/2026 04:05:54.705 7fbdb01b2e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6531 06/18/2026 04:05:54.705 7fbdb01b2e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:54.706 7fbdb01b2e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6531 (601.8381118774414 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=683819233, topics=[]) 06/18/2026 04:05:54.706 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 683819233 with 0 response partitions (1 implied) 06/18/2026 04:05:54.751 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 4462 06/18/2026 04:05:54.751 7fbdb13b92c0 [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/18/2026 04:05:54.751 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 06/18/2026 04:05:54.751 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:54.751 7fbdb13b92c0 [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=1321523926, session_epoch=6776, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:54.751 7fbdb13b92c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6790 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1321523926, session_epoch=6776, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:54.751 7fbdb13b92c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259076.689453, idle connection 436550.000000, request 304999.945641 06/18/2026 04:05:54.752 7fbdb13b92c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259076.140381, idle connection 436549.000000, request 304999.403715 06/18/2026 04:05:54.801 7fbdb13b9860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259075.192871, idle connection 198067.000000, request 304397.979259 06/18/2026 04:05:54.801 7fbdb13b9860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6355 06/18/2026 04:05:54.801 7fbdb13b9860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:54.802 7fbdb13b9860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6355 (602.7412414550781 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1380226864, topics=[]) 06/18/2026 04:05:54.802 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1380226864 with 0 response partitions (1 implied) 06/18/2026 04:05:54.812 7fbdb13b97c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257448.060059, idle connection 435237.000000, request 304398.640871 06/18/2026 04:05:54.812 7fbdb13b97c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7121 06/18/2026 04:05:54.812 7fbdb13b97c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:54.812 7fbdb13b97c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7121 (602.0491123199463 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2025868759, topics=[]) 06/18/2026 04:05:54.813 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2025868759 with 0 response partitions (1 implied) 06/18/2026 04:05:54.822 7fbdb13b99a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 261985.763184, idle connection 199228.000000, request 304398.428679 06/18/2026 04:05:54.822 7fbdb13b99a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6431 06/18/2026 04:05:54.822 7fbdb13b99a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:54.823 7fbdb13b99a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6431 (602.2598743438721 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2047323638, topics=[]) 06/18/2026 04:05:54.823 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2047323638 with 0 response partitions (1 implied) 06/18/2026 04:05:54.926 7fbdb01b2cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 170 06/18/2026 04:05:54.926 7fbdb01b2cc0 [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/18/2026 04:05:54.926 7fbdb01b2cc0 [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/18/2026 04:05:54.926 7fbdb01b2cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:54.927 7fbdb01b2cc0 [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=1059026835, session_epoch=6305, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:54.927 7fbdb01b2cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6324 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1059026835, session_epoch=6305, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:54.927 7fbdb01b2cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258446.322998, idle connection 435838.000000, request 304999.946117 06/18/2026 04:05:54.927 7fbdb13b9900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 561 06/18/2026 04:05:54.927 7fbdb13b9900 [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/18/2026 04:05:54.927 7fbdb13b9900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 06/18/2026 04:05:54.927 7fbdb13b9900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/18/2026 04:05:54.927 7fbdb13b9900 [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=1677588942, session_epoch=6365, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:54.928 7fbdb13b9900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6383 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1677588942, session_epoch=6365, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:54.928 7fbdb13b9900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258466.188721, idle connection 72866.000000, request 304999.942780 06/18/2026 04:05:54.928 7fbdb01b2cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258444.978271, idle connection 435837.000000, request 304998.607397 06/18/2026 04:05:54.929 7fbdb13b9900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258465.348877, idle connection 72865.000000, request 304999.109507 06/18/2026 04:05:54.973 7fbdb13b95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259067.835205, idle connection 198062.000000, request 304398.878336 06/18/2026 04:05:54.974 7fbdb13b95e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6368 06/18/2026 04:05:54.974 7fbdb13b95e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:54.974 7fbdb13b95e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6368 (601.7537117004395 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1098554015, topics=[]) 06/18/2026 04:05:54.974 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1098554015 with 0 response partitions (1 implied) 06/18/2026 04:05:55.022 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 370 06/18/2026 04:05:55.023 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 06/18/2026 04:05:55.023 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 06/18/2026 04:05:55.023 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/18/2026 04:05:55.023 7fbdb13b94a0 [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=206808669, session_epoch=6317, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:55.023 7fbdb13b94a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6328 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=206808669, session_epoch=6317, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:55.023 7fbdb13b94a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260871.634766, idle connection 137767.000000, request 304999.948502 06/18/2026 04:05:55.024 7fbdb13b94a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260871.244141, idle connection 137767.000000, request 304999.566078 06/18/2026 04:05:55.069 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254739.076660, idle connection 193552.000000, request 304395.558357 06/18/2026 04:05:55.069 7fbdaedf7720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9953 06/18/2026 04:05:55.069 7fbdaedf7720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:55.070 7fbdaedf7720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 9953 (605.0205230712891 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=464343197, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=53777, last_stable_offset=53777, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xd2\x10\x00\x00\x01\x04\x00\x00\x00\x00\x025b\x8e$\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/18/2026 04:05:55.070 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 464343197 with 1 response partitions (0 implied) 06/18/2026 04:05:55.070 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 53776 06/18/2026 04:05:55.070 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 53776 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 06/18/2026 04:05:55.070 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 53777 (leader epoch 0) 06/18/2026 04:05:55.171 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 53777 06/18/2026 04:05:55.172 7fbdaedf7720 [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/18/2026 04:05:55.172 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 06/18/2026 04:05:55.172 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:55.172 7fbdaedf7720 [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=464343197, session_epoch=9943, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=53777, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/18/2026 04:05:55.172 7fbdaedf7720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 9954 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=464343197, session_epoch=9943, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=53777, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/18/2026 04:05:55.172 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254635.884766, idle connection 193449.000000, request 304999.948740 06/18/2026 04:05:55.173 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254635.450684, idle connection 193449.000000, request 304999.522924 06/18/2026 04:05:55.254 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 255 06/18/2026 04:05:55.254 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 06/18/2026 04:05:55.255 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 06/18/2026 04:05:55.255 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/18/2026 04:05:55.255 7fbdb01b2f40 [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=1674122441, session_epoch=6319, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:55.255 7fbdb01b2f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6337 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1674122441, session_epoch=6319, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:55.255 7fbdb01b2f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259613.733887, idle connection 198609.000000, request 304999.915600 06/18/2026 04:05:55.256 7fbdb01b2f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259613.121094, idle connection 198608.000000, request 304999.314785 06/18/2026 04:05:55.306 7fbdaf3dd220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259873.292725, idle connection 198557.000000, request 304398.283005 06/18/2026 04:05:55.306 7fbdaf3dd220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6544 06/18/2026 04:05:55.306 7fbdaf3dd220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:55.307 7fbdaf3dd220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6544 (602.5958061218262 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=515211984, topics=[]) 06/18/2026 04:05:55.307 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 515211984 with 0 response partitions (1 implied) 06/18/2026 04:05:55.307 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 1340 06/18/2026 04:05:55.307 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 06/18/2026 04:05:55.307 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)]) 06/18/2026 04:05:55.307 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:55.308 7fbdb01b2e00 [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=683819233, session_epoch=6509, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:55.308 7fbdb01b2e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6532 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=683819233, session_epoch=6509, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:55.308 7fbdb01b2e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257453.067139, idle connection 194601.000000, request 304999.939203 06/18/2026 04:05:55.308 7fbdb01b2e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257452.580566, idle connection 194600.000000, request 304999.457359 06/18/2026 04:05:55.353 7fbdb13b92c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258475.140137, idle connection 435948.000000, request 304398.394585 06/18/2026 04:05:55.353 7fbdb13b92c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6790 06/18/2026 04:05:55.353 7fbdb13b92c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:55.353 7fbdb13b92c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6790 (602.1521091461182 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1321523926, topics=[]) 06/18/2026 04:05:55.354 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1321523926 with 0 response partitions (1 implied) 06/18/2026 04:05:55.403 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 425 06/18/2026 04:05:55.404 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 06/18/2026 04:05:55.404 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 06/18/2026 04:05:55.404 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/18/2026 04:05:55.404 7fbdb13b9860 [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=1380226864, session_epoch=6346, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:55.404 7fbdb13b9860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6356 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1380226864, session_epoch=6346, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:55.404 7fbdb13b9860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258471.842773, idle connection 197464.000000, request 304999.944448 06/18/2026 04:05:55.405 7fbdb13b9860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258471.408203, idle connection 197463.000000, request 304999.518871 06/18/2026 04:05:55.413 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 4877 06/18/2026 04:05:55.414 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 06/18/2026 04:05:55.414 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 06/18/2026 04:05:55.414 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/18/2026 04:05:55.414 7fbdb13b97c0 [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=2025868759, session_epoch=7102, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:55.414 7fbdb13b97c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7122 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2025868759, session_epoch=7102, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:55.414 7fbdb13b97c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256845.577881, idle connection 434635.000000, request 304999.946356 06/18/2026 04:05:55.415 7fbdb13b97c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256844.865479, idle connection 434634.000000, request 304999.241829 06/18/2026 04:05:55.424 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 654 06/18/2026 04:05:55.424 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 06/18/2026 04:05:55.424 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 06/18/2026 04:05:55.424 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/18/2026 04:05:55.424 7fbdb13b99a0 [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=2047323638, session_epoch=6418, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:55.424 7fbdb13b99a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6432 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2047323638, session_epoch=6418, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:55.425 7fbdb13b99a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 261382.920166, idle connection 198625.000000, request 304999.944210 06/18/2026 04:05:55.425 7fbdb13b99a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 261382.492432, idle connection 198625.000000, request 304999.521732 06/18/2026 04:05:55.529 7fbdb01b2cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257844.045166, idle connection 435236.000000, request 304397.668839 06/18/2026 04:05:55.529 7fbdb01b2cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6324 06/18/2026 04:05:55.530 7fbdb01b2cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:55.530 7fbdb01b2cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6324 (602.8783321380615 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1059026835, topics=[]) 06/18/2026 04:05:55.530 7fbdb01b2cc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1059026835 with 0 response partitions (1 implied) 06/18/2026 04:05:55.530 7fbdb13b9900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257863.934570, idle connection 72264.000000, request 304397.695065 06/18/2026 04:05:55.530 7fbdb13b9900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6383 06/18/2026 04:05:55.530 7fbdb13b9900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:55.530 7fbdb13b9900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6383 (602.6432514190674 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1677588942, topics=[]) 06/18/2026 04:05:55.531 7fbdb13b9900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1677588942 with 0 response partitions (1 implied) 06/18/2026 04:05:55.575 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 505 06/18/2026 04:05:55.575 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 06/18/2026 04:05:55.575 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 06/18/2026 04:05:55.575 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/18/2026 04:05:55.575 7fbdb13b95e0 [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=1098554015, session_epoch=6357, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:55.575 7fbdb13b95e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6369 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1098554015, session_epoch=6357, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:55.575 7fbdb13b95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258465.544678, idle connection 197460.000000, request 304999.930620 06/18/2026 04:05:55.576 7fbdb13b95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258465.118408, idle connection 197460.000000, request 304999.511003 06/18/2026 04:05:55.625 7fbdb13b94a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260269.747559, idle connection 137165.000000, request 304398.059368 06/18/2026 04:05:55.625 7fbdb13b94a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6328 06/18/2026 04:05:55.625 7fbdb13b94a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:55.626 7fbdb13b94a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6328 (602.4801731109619 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=206808669, topics=[]) 06/18/2026 04:05:55.626 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 206808669 with 0 response partitions (1 implied) 06/18/2026 04:05:55.773 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254034.818359, idle connection 192848.000000, request 304398.880482 06/18/2026 04:05:55.774 7fbdaedf7720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9954 06/18/2026 04:05:55.774 7fbdaedf7720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:55.774 7fbdaedf7720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 9954 (601.6976833343506 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=464343197, topics=[]) 06/18/2026 04:05:55.774 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 464343197 with 0 response partitions (1 implied) 06/18/2026 04:05:55.857 7fbdb01b2f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259011.788574, idle connection 198007.000000, request 304397.977829 06/18/2026 04:05:55.858 7fbdb01b2f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6337 06/18/2026 04:05:55.858 7fbdb01b2f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:55.858 7fbdb01b2f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6337 (602.5843620300293 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1674122441, topics=[]) 06/18/2026 04:05:55.858 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1674122441 with 0 response partitions (1 implied) 06/18/2026 04:05:55.908 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 1898 06/18/2026 04:05:55.908 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 06/18/2026 04:05:55.908 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 06/18/2026 04:05:55.908 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/18/2026 04:05:55.909 7fbdaf3dd220 [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=515211984, session_epoch=6532, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:55.909 7fbdaf3dd220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6545 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=515211984, session_epoch=6532, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:55.909 7fbdaf3dd220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259270.249268, idle connection 197953.000000, request 304999.948025 06/18/2026 04:05:55.909 7fbdaf3dd220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259269.851074, idle connection 197953.000000, request 304999.558449 06/18/2026 04:05:55.909 7fbdb01b2e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256851.556396, idle connection 193999.000000, request 304398.437023 06/18/2026 04:05:55.910 7fbdb01b2e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6532 06/18/2026 04:05:55.910 7fbdb01b2e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:55.910 7fbdb01b2e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6532 (602.0534038543701 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=683819233, topics=[]) 06/18/2026 04:05:55.910 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 683819233 with 0 response partitions (1 implied) 06/18/2026 04:05:55.954 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 4462 06/18/2026 04:05:55.955 7fbdb13b92c0 [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/18/2026 04:05:55.955 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 06/18/2026 04:05:55.955 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:55.955 7fbdb13b92c0 [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=1321523926, session_epoch=6777, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:55.955 7fbdb13b92c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6791 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1321523926, session_epoch=6777, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:55.955 7fbdb13b92c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257872.797363, idle connection 435346.000000, request 304999.945402 06/18/2026 04:05:55.956 7fbdb13b92c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257872.298096, idle connection 435346.000000, request 304999.450207 06/18/2026 04:05:56.005 7fbdb13b9860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257870.889404, idle connection 196863.000000, request 304398.991585 06/18/2026 04:05:56.005 7fbdb13b9860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6356 06/18/2026 04:05:56.006 7fbdb13b9860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:56.006 7fbdb13b9860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6356 (601.6082763671875 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1380226864, topics=[]) 06/18/2026 04:05:56.006 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1380226864 with 0 response partitions (1 implied) 06/18/2026 04:05:56.016 7fbdb13b97c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256243.917480, idle connection 434033.000000, request 304398.286104 06/18/2026 04:05:56.017 7fbdb13b97c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7122 06/18/2026 04:05:56.018 7fbdb13b97c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:56.018 7fbdb13b97c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7122 (604.1162014007568 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2025868759, topics=[]) 06/18/2026 04:05:56.019 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2025868759 with 0 response partitions (1 implied) 06/18/2026 04:05:56.026 7fbdb13b99a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260781.966309, idle connection 198024.000000, request 304398.992300 06/18/2026 04:05:56.026 7fbdb13b99a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6432 06/18/2026 04:05:56.026 7fbdb13b99a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:56.026 7fbdb13b99a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6432 (601.4373302459717 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2047323638, topics=[]) 06/18/2026 04:05:56.026 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2047323638 with 0 response partitions (1 implied) 06/18/2026 04:05:56.131 7fbdb01b2cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 170 06/18/2026 04:05:56.131 7fbdb01b2cc0 [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/18/2026 04:05:56.132 7fbdb01b2cc0 [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/18/2026 04:05:56.132 7fbdb01b2cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:56.132 7fbdb01b2cc0 [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=1059026835, session_epoch=6306, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:56.132 7fbdb01b2cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6325 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1059026835, session_epoch=6306, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:56.132 7fbdb01b2cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257241.106201, idle connection 434633.000000, request 304999.946356 06/18/2026 04:05:56.132 7fbdb13b9900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 561 06/18/2026 04:05:56.132 7fbdb13b9900 [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/18/2026 04:05:56.132 7fbdb13b9900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 06/18/2026 04:05:56.133 7fbdb13b9900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/18/2026 04:05:56.133 7fbdb13b9900 [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=1677588942, session_epoch=6366, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:56.133 7fbdb13b9900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6384 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1677588942, session_epoch=6366, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:56.133 7fbdb13b9900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257261.025879, idle connection 71661.000000, request 304999.952555 06/18/2026 04:05:56.133 7fbdb01b2cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257239.852783, idle connection 434631.000000, request 304998.702526 06/18/2026 04:05:56.134 7fbdb13b9900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257260.258057, idle connection 71660.000000, request 304999.189615 06/18/2026 04:05:56.176 7fbdb13b95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257864.550537, idle connection 196859.000000, request 304398.932695 06/18/2026 04:05:56.177 7fbdb13b95e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6369 06/18/2026 04:05:56.177 7fbdb13b95e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:56.177 7fbdb13b95e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6369 (601.7229557037354 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1098554015, topics=[]) 06/18/2026 04:05:56.177 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1098554015 with 0 response partitions (1 implied) 06/18/2026 04:05:56.227 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 370 06/18/2026 04:05:56.227 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 06/18/2026 04:05:56.227 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 06/18/2026 04:05:56.227 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/18/2026 04:05:56.227 7fbdb13b94a0 [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=206808669, session_epoch=6318, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:56.228 7fbdb13b94a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6329 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=206808669, session_epoch=6318, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:56.228 7fbdb13b94a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259666.938232, idle connection 136562.000000, request 304999.940395 06/18/2026 04:05:56.228 7fbdb13b94a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259666.352295, idle connection 136562.000000, request 304999.299288 06/18/2026 04:05:56.375 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 53777 06/18/2026 04:05:56.375 7fbdaedf7720 [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/18/2026 04:05:56.375 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 06/18/2026 04:05:56.375 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:56.375 7fbdaedf7720 [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=464343197, session_epoch=9944, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:56.375 7fbdaedf7720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 9955 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=464343197, session_epoch=9944, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:56.376 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 253432.427002, idle connection 192246.000000, request 304999.940872 06/18/2026 04:05:56.376 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 253431.966309, idle connection 192245.000000, request 304999.489069 06/18/2026 04:05:56.458 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 255 06/18/2026 04:05:56.459 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 06/18/2026 04:05:56.459 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 06/18/2026 04:05:56.459 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/18/2026 04:05:56.459 7fbdb01b2f40 [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=1674122441, session_epoch=6320, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:56.459 7fbdb01b2f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6338 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1674122441, session_epoch=6320, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:56.460 7fbdb01b2f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258409.270264, idle connection 197404.000000, request 304999.940157 06/18/2026 04:05:56.460 7fbdb01b2f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258408.530762, idle connection 197404.000000, request 304999.206066 06/18/2026 04:05:56.510 7fbdaf3dd220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258668.987061, idle connection 197352.000000, request 304398.681641 06/18/2026 04:05:56.511 7fbdaf3dd220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6545 06/18/2026 04:05:56.511 7fbdaf3dd220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:56.511 7fbdaf3dd220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6545 (602.1969318389893 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=515211984, topics=[]) 06/18/2026 04:05:56.511 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 515211984 with 0 response partitions (1 implied) 06/18/2026 04:05:56.512 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 1340 06/18/2026 04:05:56.512 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 06/18/2026 04:05:56.512 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)]) 06/18/2026 04:05:56.512 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:56.512 7fbdb01b2e00 [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=683819233, session_epoch=6510, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:56.513 7fbdb01b2e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6533 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=683819233, session_epoch=6510, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:56.513 7fbdb01b2e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256248.239746, idle connection 193396.000000, request 304999.936581 06/18/2026 04:05:56.513 7fbdb01b2e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256247.726562, idle connection 193396.000000, request 304999.429941 06/18/2026 04:05:56.558 7fbdb13b92c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257269.914062, idle connection 434743.000000, request 304397.037029 06/18/2026 04:05:56.559 7fbdb13b92c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6791 06/18/2026 04:05:56.559 7fbdb13b92c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:56.559 7fbdb13b92c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6791 (604.0816307067871 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1321523926, topics=[]) 06/18/2026 04:05:56.560 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1321523926 with 0 response partitions (1 implied) 06/18/2026 04:05:56.606 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 425 06/18/2026 04:05:56.607 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 06/18/2026 04:05:56.607 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 06/18/2026 04:05:56.607 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/18/2026 04:05:56.607 7fbdb13b9860 [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=1380226864, session_epoch=6347, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:56.607 7fbdb13b9860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6357 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1380226864, session_epoch=6347, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:56.607 7fbdb13b9860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257268.745605, idle connection 196261.000000, request 304999.947071 06/18/2026 04:05:56.608 7fbdb13b9860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257268.130615, idle connection 196260.000000, request 304999.336720 06/18/2026 04:05:56.619 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 4877 06/18/2026 04:05:56.620 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 06/18/2026 04:05:56.620 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 06/18/2026 04:05:56.620 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/18/2026 04:05:56.620 7fbdb13b97c0 [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=2025868759, session_epoch=7103, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:56.620 7fbdb13b97c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7123 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2025868759, session_epoch=7103, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:56.621 7fbdb13b97c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255639.185547, idle connection 433428.000000, request 304999.932289 06/18/2026 04:05:56.621 7fbdb13b97c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255638.457031, idle connection 433428.000000, request 304999.212265 06/18/2026 04:05:56.627 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 654 06/18/2026 04:05:56.627 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 06/18/2026 04:05:56.627 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 06/18/2026 04:05:56.627 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/18/2026 04:05:56.627 7fbdb13b99a0 [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=2047323638, session_epoch=6419, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:56.627 7fbdb13b99a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6433 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2047323638, session_epoch=6419, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:56.627 7fbdb13b99a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260180.204102, idle connection 197422.000000, request 304999.952793 06/18/2026 04:05:56.628 7fbdb13b99a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 260179.730957, idle connection 197422.000000, request 304999.484301 06/18/2026 04:05:56.735 7fbdb01b2cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256637.965576, idle connection 434030.000000, request 304396.806955 06/18/2026 04:05:56.736 7fbdb01b2cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6325 06/18/2026 04:05:56.736 7fbdb01b2cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:56.736 7fbdb01b2cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6325 (603.7981510162354 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1059026835, topics=[]) 06/18/2026 04:05:56.736 7fbdb01b2cc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1059026835 with 0 response partitions (1 implied) 06/18/2026 04:05:56.736 7fbdb13b9900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256657.743652, idle connection 71058.000000, request 304396.669149 06/18/2026 04:05:56.736 7fbdb13b9900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6384 06/18/2026 04:05:56.737 7fbdb13b9900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:56.737 7fbdb13b9900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6384 (603.7273406982422 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1677588942, topics=[]) 06/18/2026 04:05:56.737 7fbdb13b9900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1677588942 with 0 response partitions (1 implied) 06/18/2026 04:05:56.778 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 505 06/18/2026 04:05:56.779 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 06/18/2026 04:05:56.779 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 06/18/2026 04:05:56.779 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/18/2026 04:05:56.779 7fbdb13b95e0 [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=1098554015, session_epoch=6358, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:56.779 7fbdb13b95e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6370 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1098554015, session_epoch=6358, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:56.779 7fbdb13b95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257261.759033, idle connection 196256.000000, request 304999.948740 06/18/2026 04:05:56.780 7fbdb13b95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257261.275146, idle connection 196256.000000, request 304999.471903 06/18/2026 04:05:56.830 7fbdb13b94a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259064.938721, idle connection 135960.000000, request 304397.942305 06/18/2026 04:05:56.830 7fbdb13b94a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6329 06/18/2026 04:05:56.830 7fbdb13b94a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:56.831 7fbdb13b94a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6329 (602.7424335479736 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=206808669, topics=[]) 06/18/2026 04:05:56.831 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 206808669 with 0 response partitions (1 implied) 06/18/2026 04:05:56.977 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 252831.355713, idle connection 191645.000000, request 304398.870468 06/18/2026 04:05:56.977 7fbdaedf7720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9955 06/18/2026 04:05:56.977 7fbdaedf7720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:56.977 7fbdaedf7720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 9955 (601.6669273376465 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=464343197, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=53778, last_stable_offset=53778, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xd2\x11\x00\x00\x01\x04\x00\x00\x00\x00\x02\x83\xab"\xb8\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/18/2026 04:05:56.977 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 464343197 with 1 response partitions (0 implied) 06/18/2026 04:05:56.978 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 53777 06/18/2026 04:05:56.978 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 53777 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 06/18/2026 04:05:56.978 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 53778 (leader epoch 0) 06/18/2026 04:05:57.061 7fbdb01b2f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257807.872070, idle connection 196803.000000, request 304398.542643 06/18/2026 04:05:57.061 7fbdb01b2f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6338 06/18/2026 04:05:57.061 7fbdb01b2f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:57.062 7fbdb01b2f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6338 (601.9778251647949 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1674122441, topics=[]) 06/18/2026 04:05:57.062 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1674122441 with 0 response partitions (1 implied) 06/18/2026 04:05:57.079 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 53778 06/18/2026 04:05:57.079 7fbdaedf7720 [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/18/2026 04:05:57.079 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 06/18/2026 04:05:57.079 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:57.079 7fbdaedf7720 [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=464343197, session_epoch=9945, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=53778, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/18/2026 04:05:57.079 7fbdaedf7720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 9956 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=464343197, session_epoch=9945, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=53778, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/18/2026 04:05:57.079 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 252728.790283, idle connection 191542.000000, request 304999.946117 06/18/2026 04:05:57.080 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 252728.355713, idle connection 191542.000000, request 304999.519587 06/18/2026 04:05:57.112 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 1898 06/18/2026 04:05:57.112 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 06/18/2026 04:05:57.112 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 06/18/2026 04:05:57.112 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/18/2026 04:05:57.113 7fbdaf3dd220 [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=515211984, session_epoch=6533, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:57.113 7fbdaf3dd220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6546 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=515211984, session_epoch=6533, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:57.113 7fbdaf3dd220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258066.240723, idle connection 196749.000000, request 304999.949455 06/18/2026 04:05:57.113 7fbdaf3dd220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258065.859131, idle connection 196749.000000, request 304999.574661 06/18/2026 04:05:57.114 7fbdb01b2e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255647.361328, idle connection 192795.000000, request 304399.067879 06/18/2026 04:05:57.114 7fbdb01b2e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6533 06/18/2026 04:05:57.114 7fbdb01b2e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:57.114 7fbdb01b2e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6533 (601.2663841247559 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=683819233, topics=[]) 06/18/2026 04:05:57.114 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 683819233 with 0 response partitions (1 implied) 06/18/2026 04:05:57.160 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 4462 06/18/2026 04:05:57.161 7fbdb13b92c0 [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/18/2026 04:05:57.161 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 06/18/2026 04:05:57.161 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:57.161 7fbdb13b92c0 [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=1321523926, session_epoch=6778, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:57.161 7fbdb13b92c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6792 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1321523926, session_epoch=6778, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:57.161 7fbdb13b92c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256666.711914, idle connection 434140.000000, request 304999.944448 06/18/2026 04:05:57.162 7fbdb13b92c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256666.220947, idle connection 434139.000000, request 304999.454975 06/18/2026 04:05:57.208 7fbdb13b9860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256667.485596, idle connection 195659.000000, request 304398.687601 06/18/2026 04:05:57.209 7fbdb13b9860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6357 06/18/2026 04:05:57.209 7fbdb13b9860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:57.209 7fbdb13b9860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6357 (601.9408702850342 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1380226864, topics=[]) 06/18/2026 04:05:57.209 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1380226864 with 0 response partitions (1 implied) 06/18/2026 04:05:57.222 7fbdb13b97c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255037.936768, idle connection 432827.000000, request 304398.684740 06/18/2026 04:05:57.222 7fbdb13b97c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7123 06/18/2026 04:05:57.222 7fbdb13b97c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:57.223 7fbdb13b97c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7123 (602.0441055297852 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2025868759, topics=[]) 06/18/2026 04:05:57.223 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2025868759 with 0 response partitions (1 implied) 06/18/2026 04:05:57.228 7fbdb13b99a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 259579.106934, idle connection 196821.000000, request 304398.855448 06/18/2026 04:05:57.229 7fbdb13b99a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6433 06/18/2026 04:05:57.229 7fbdb13b99a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:57.229 7fbdb13b99a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6433 (601.6371250152588 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2047323638, topics=[]) 06/18/2026 04:05:57.229 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2047323638 with 0 response partitions (1 implied) 06/18/2026 04:05:57.336 7fbdb01b2cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 170 06/18/2026 04:05:57.337 7fbdb01b2cc0 [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/18/2026 04:05:57.337 7fbdb01b2cc0 [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/18/2026 04:05:57.337 7fbdb01b2cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:57.337 7fbdb01b2cc0 [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=1059026835, session_epoch=6307, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:57.337 7fbdb01b2cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6326 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1059026835, session_epoch=6307, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:57.337 7fbdb01b2cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256036.081299, idle connection 433428.000000, request 304999.950171 06/18/2026 04:05:57.337 7fbdb13b9900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 561 06/18/2026 04:05:57.337 7fbdb13b9900 [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/18/2026 04:05:57.337 7fbdb13b9900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 06/18/2026 04:05:57.338 7fbdb13b9900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/18/2026 04:05:57.338 7fbdb13b9900 [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=1677588942, session_epoch=6367, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:57.338 7fbdb13b9900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6385 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1677588942, session_epoch=6367, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:57.338 7fbdb13b9900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256056.157715, idle connection 70456.000000, request 304999.962091 06/18/2026 04:05:57.338 7fbdb01b2cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256034.989746, idle connection 433427.000000, request 304998.865604 06/18/2026 04:05:57.339 7fbdb13b9900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256055.390625, idle connection 70455.000000, request 304999.198914 06/18/2026 04:05:57.380 7fbdb13b95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256660.703125, idle connection 195655.000000, request 304398.891926 06/18/2026 04:05:57.381 7fbdb13b95e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6370 06/18/2026 04:05:57.381 7fbdb13b95e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:57.381 7fbdb13b95e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6370 (601.743221282959 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1098554015, topics=[]) 06/18/2026 04:05:57.381 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1098554015 with 0 response partitions (1 implied) 06/18/2026 04:05:57.431 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 370 06/18/2026 04:05:57.431 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 06/18/2026 04:05:57.431 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 06/18/2026 04:05:57.431 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/18/2026 04:05:57.432 7fbdb13b94a0 [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=206808669, session_epoch=6319, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:57.432 7fbdb13b94a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6330 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=206808669, session_epoch=6319, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:57.432 7fbdb13b94a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258462.895020, idle connection 135358.000000, request 304999.947309 06/18/2026 04:05:57.432 7fbdb13b94a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258462.504150, idle connection 135358.000000, request 304999.562979 06/18/2026 04:05:57.662 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 255 06/18/2026 04:05:57.662 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 06/18/2026 04:05:57.663 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 06/18/2026 04:05:57.663 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/18/2026 04:05:57.663 7fbdb01b2f40 [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=1674122441, session_epoch=6321, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:57.663 7fbdb01b2f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6339 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1674122441, session_epoch=6321, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:57.663 7fbdb01b2f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257205.920410, idle connection 196201.000000, request 304999.941587 06/18/2026 04:05:57.663 7fbdb01b2f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257205.459473, idle connection 196201.000000, request 304999.490499 06/18/2026 04:05:57.680 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 252127.824707, idle connection 190941.000000, request 304398.981333 06/18/2026 04:05:57.681 7fbdaedf7720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9956 06/18/2026 04:05:57.681 7fbdaedf7720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:57.681 7fbdaedf7720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 9956 (601.62353515625 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=464343197, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=53779, last_stable_offset=53779, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xd2\x12\x00\x00\x01\x04\x00\x00\x00\x00\x02\xbc+\xb8\xb2\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/18/2026 04:05:57.681 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 464343197 with 1 response partitions (0 implied) 06/18/2026 04:05:57.681 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 53778 06/18/2026 04:05:57.681 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 53778 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 06/18/2026 04:05:57.682 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 53779 (leader epoch 0) 06/18/2026 04:05:57.714 7fbdaf3dd220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257465.369629, idle connection 196149.000000, request 304399.075508 06/18/2026 04:05:57.714 7fbdaf3dd220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6546 06/18/2026 04:05:57.714 7fbdaf3dd220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:57.714 7fbdaf3dd220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6546 (601.5331745147705 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=515211984, topics=[]) 06/18/2026 04:05:57.714 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 515211984 with 0 response partitions (1 implied) 06/18/2026 04:05:57.715 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 1340 06/18/2026 04:05:57.715 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 06/18/2026 04:05:57.715 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)]) 06/18/2026 04:05:57.715 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:57.715 7fbdb01b2e00 [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=683819233, session_epoch=6511, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:57.715 7fbdb01b2e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6534 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=683819233, session_epoch=6511, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:57.715 7fbdb01b2e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255045.721436, idle connection 192194.000000, request 304999.954700 06/18/2026 04:05:57.716 7fbdb01b2e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255045.326904, idle connection 192193.000000, request 304999.558687 06/18/2026 04:05:57.763 7fbdb13b92c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256065.521484, idle connection 433539.000000, request 304398.754358 06/18/2026 04:05:57.763 7fbdb13b92c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6792 06/18/2026 04:05:57.763 7fbdb13b92c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:57.763 7fbdb13b92c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6792 (601.771354675293 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1321523926, topics=[]) 06/18/2026 04:05:57.763 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1321523926 with 0 response partitions (1 implied) 06/18/2026 04:05:57.783 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 53779 06/18/2026 04:05:57.783 7fbdaedf7720 [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/18/2026 04:05:57.783 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 06/18/2026 04:05:57.784 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:57.784 7fbdaedf7720 [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=464343197, session_epoch=9946, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=53779, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/18/2026 04:05:57.784 7fbdaedf7720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 9957 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=464343197, session_epoch=9946, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=53779, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/18/2026 04:05:57.784 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 252024.010254, idle connection 190837.000000, request 304999.915123 06/18/2026 04:05:57.785 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 252023.376709, idle connection 190837.000000, request 304999.292612 06/18/2026 04:05:57.810 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 425 06/18/2026 04:05:57.810 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 06/18/2026 04:05:57.810 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 06/18/2026 04:05:57.810 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/18/2026 04:05:57.810 7fbdb13b9860 [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=1380226864, session_epoch=6348, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:57.811 7fbdb13b9860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6358 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1380226864, session_epoch=6348, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:57.811 7fbdb13b9860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256065.195068, idle connection 195057.000000, request 304999.928713 06/18/2026 04:05:57.811 7fbdb13b9860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256064.618896, idle connection 195057.000000, request 304999.363899 06/18/2026 04:05:57.823 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 4877 06/18/2026 04:05:57.823 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 06/18/2026 04:05:57.823 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 06/18/2026 04:05:57.823 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/18/2026 04:05:57.824 7fbdb13b97c0 [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=2025868759, session_epoch=7104, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:57.824 7fbdb13b97c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7124 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2025868759, session_epoch=7104, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:57.824 7fbdb13b97c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254435.718262, idle connection 432225.000000, request 304999.926567 06/18/2026 04:05:57.825 7fbdb13b97c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254435.175049, idle connection 432224.000000, request 304999.395609 06/18/2026 04:05:57.830 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 654 06/18/2026 04:05:57.830 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 06/18/2026 04:05:57.830 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 06/18/2026 04:05:57.830 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/18/2026 04:05:57.830 7fbdb13b99a0 [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=2047323638, session_epoch=6420, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:57.830 7fbdb13b99a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6434 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2047323638, session_epoch=6420, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:57.830 7fbdb13b99a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258977.296875, idle connection 196220.000000, request 304999.953508 06/18/2026 04:05:57.831 7fbdb13b99a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258976.922363, idle connection 196219.000000, request 304999.584198 06/18/2026 04:05:57.939 7fbdb01b2cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255434.032715, idle connection 432826.000000, request 304397.900581 06/18/2026 04:05:57.940 7fbdb01b2cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6326 06/18/2026 04:05:57.940 7fbdb01b2cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:57.940 7fbdb01b2cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6326 (602.7143001556396 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1059026835, topics=[]) 06/18/2026 04:05:57.940 7fbdb01b2cc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1059026835 with 0 response partitions (1 implied) 06/18/2026 04:05:57.940 7fbdb13b9900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255453.745117, idle connection 69854.000000, request 304397.551060 06/18/2026 04:05:57.940 7fbdb13b9900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6385 06/18/2026 04:05:57.940 7fbdb13b9900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:57.941 7fbdb13b9900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6385 (602.7662754058838 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1677588942, topics=[]) 06/18/2026 04:05:57.941 7fbdb13b9900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1677588942 with 0 response partitions (1 implied) 06/18/2026 04:05:57.982 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 505 06/18/2026 04:05:57.982 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 06/18/2026 04:05:57.982 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 06/18/2026 04:05:57.982 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/18/2026 04:05:57.982 7fbdb13b95e0 [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=1098554015, session_epoch=6359, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:57.982 7fbdb13b95e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6371 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1098554015, session_epoch=6359, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:57.982 7fbdb13b95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256058.714600, idle connection 195053.000000, request 304999.948263 06/18/2026 04:05:57.983 7fbdb13b95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256058.262939, idle connection 195053.000000, request 304999.504328 06/18/2026 04:05:58.033 7fbdb13b94a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257861.987549, idle connection 134757.000000, request 304399.039268 06/18/2026 04:05:58.033 7fbdb13b94a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6330 06/18/2026 04:05:58.033 7fbdb13b94a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:58.033 7fbdb13b94a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6330 (601.5369892120361 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=206808669, topics=[]) 06/18/2026 04:05:58.034 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 206808669 with 0 response partitions (1 implied) 06/18/2026 04:05:58.265 7fbdb01b2f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256604.016357, idle connection 195599.000000, request 304398.038626 06/18/2026 04:05:58.271 7fbdb01b2f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6339 06/18/2026 04:05:58.273 7fbdb01b2f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:58.274 7fbdb01b2f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6339 (611.2453937530518 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1674122441, topics=[]) 06/18/2026 04:05:58.274 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1674122441 with 0 response partitions (1 implied) 06/18/2026 04:05:58.315 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 1898 06/18/2026 04:05:58.315 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 06/18/2026 04:05:58.315 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 06/18/2026 04:05:58.315 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/18/2026 04:05:58.316 7fbdaf3dd220 [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=515211984, session_epoch=6534, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:58.316 7fbdaf3dd220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6547 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=515211984, session_epoch=6534, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:58.316 7fbdaf3dd220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256863.135742, idle connection 195546.000000, request 304999.940634 06/18/2026 04:05:58.316 7fbdb01b2e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254444.778320, idle connection 191593.000000, request 304399.014473 06/18/2026 04:05:58.317 7fbdaf3dd220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256862.523438, idle connection 195546.000000, request 304999.327898 06/18/2026 04:05:58.317 7fbdb01b2e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6534 06/18/2026 04:05:58.317 7fbdb01b2e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:58.317 7fbdb01b2e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6534 (601.7425060272217 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=683819233, topics=[]) 06/18/2026 04:05:58.317 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 683819233 with 0 response partitions (1 implied) 06/18/2026 04:05:58.364 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 4462 06/18/2026 04:05:58.364 7fbdb13b92c0 [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/18/2026 04:05:58.364 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 06/18/2026 04:05:58.364 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:58.364 7fbdb13b92c0 [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=1321523926, session_epoch=6779, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:58.364 7fbdb13b92c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6793 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1321523926, session_epoch=6779, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:58.364 7fbdb13b92c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255463.527344, idle connection 432937.000000, request 304999.948025 06/18/2026 04:05:58.365 7fbdb13b92c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255463.094727, idle connection 432936.000000, request 304999.523878 06/18/2026 04:05:58.385 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 251422.798584, idle connection 190236.000000, request 304398.710966 06/18/2026 04:05:58.386 7fbdaedf7720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9957 06/18/2026 04:05:58.386 7fbdaedf7720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:58.386 7fbdaedf7720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 9957 (601.8657684326172 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=464343197, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=53781, last_stable_offset=53781, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xd2\x13\x00\x00\x01\x04\x00\x00\x00\x00\x02o\xd3\x97\x1a\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/18/2026 04:05:58.386 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 464343197 with 1 response partitions (0 implied) 06/18/2026 04:05:58.386 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 558 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 53779 06/18/2026 04:05:58.386 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 53779 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 06/18/2026 04:05:58.387 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 53781 (leader epoch 0) 06/18/2026 04:05:58.412 7fbdb13b9860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255463.976074, idle connection 194456.000000, request 304398.713589 06/18/2026 04:05:58.412 7fbdb13b9860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6358 06/18/2026 04:05:58.412 7fbdb13b9860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:58.413 7fbdb13b9860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6358 (601.801872253418 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1380226864, topics=[]) 06/18/2026 04:05:58.413 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1380226864 with 0 response partitions (1 implied) 06/18/2026 04:05:58.425 7fbdb13b97c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 253834.519287, idle connection 431624.000000, request 304398.731470 06/18/2026 04:05:58.426 7fbdb13b97c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7124 06/18/2026 04:05:58.426 7fbdb13b97c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:58.426 7fbdb13b97c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 7124 (601.9287109375 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2025868759, topics=[]) 06/18/2026 04:05:58.426 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2025868759 with 0 response partitions (1 implied) 06/18/2026 04:05:58.431 7fbdb13b99a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 258376.397949, idle connection 195619.000000, request 304399.054527 06/18/2026 04:05:58.431 7fbdb13b99a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6434 06/18/2026 04:05:58.432 7fbdb13b99a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:58.432 7fbdb13b99a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6434 (601.4208793640137 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2047323638, topics=[]) 06/18/2026 04:05:58.432 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 2047323638 with 0 response partitions (1 implied) 06/18/2026 04:05:58.487 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 53781 06/18/2026 04:05:58.487 7fbdaedf7720 [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/18/2026 04:05:58.487 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 06/18/2026 04:05:58.488 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:58.488 7fbdaedf7720 [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=464343197, session_epoch=9947, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=53781, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/18/2026 04:05:58.488 7fbdaedf7720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 9958 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=464343197, session_epoch=9947, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=53781, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/18/2026 04:05:58.489 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 251319.360840, idle connection 190133.000000, request 304999.934673 06/18/2026 04:05:58.489 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 251318.920166, idle connection 190132.000000, request 304999.504805 06/18/2026 04:05:58.540 7fbdb01b2cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 170 06/18/2026 04:05:58.541 7fbdb01b2cc0 [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/18/2026 04:05:58.541 7fbdb01b2cc0 [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/18/2026 04:05:58.541 7fbdb01b2cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:58.541 7fbdb01b2cc0 [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=1059026835, session_epoch=6308, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:58.541 7fbdb01b2cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6327 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1059026835, session_epoch=6308, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:58.541 7fbdb01b2cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254832.010254, idle connection 432224.000000, request 304999.948740 06/18/2026 04:05:58.541 7fbdb13b9900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 561 06/18/2026 04:05:58.541 7fbdb13b9900 [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/18/2026 04:05:58.541 7fbdb13b9900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 06/18/2026 04:05:58.542 7fbdb13b9900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/18/2026 04:05:58.542 7fbdb13b9900 [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=1677588942, session_epoch=6368, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:58.542 7fbdb13b9900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6386 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1677588942, session_epoch=6368, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:58.542 7fbdb13b9900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254852.130371, idle connection 69252.000000, request 304999.961138 06/18/2026 04:05:58.542 7fbdb01b2cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254830.990479, idle connection 432223.000000, request 304998.937368 06/18/2026 04:05:58.542 7fbdb13b9900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254851.493652, idle connection 69251.000000, request 304999.328375 06/18/2026 04:05:58.584 7fbdb13b95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255457.525391, idle connection 194452.000000, request 304398.481369 06/18/2026 04:05:58.584 7fbdb13b95e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6371 06/18/2026 04:05:58.584 7fbdb13b95e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:58.585 7fbdb13b95e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6371 (602.3538112640381 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1098554015, topics=[]) 06/18/2026 04:05:58.585 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1098554015 with 0 response partitions (1 implied) 06/18/2026 04:05:58.634 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 370 06/18/2026 04:05:58.634 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 06/18/2026 04:05:58.634 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 06/18/2026 04:05:58.634 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/18/2026 04:05:58.634 7fbdb13b94a0 [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=206808669, session_epoch=6320, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:58.635 7fbdb13b94a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6331 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=206808669, session_epoch=6320, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:58.635 7fbdb13b94a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257260.055420, idle connection 134155.000000, request 304999.947309 06/18/2026 04:05:58.635 7fbdb13b94a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257259.664795, idle connection 134155.000000, request 304999.564648 06/18/2026 04:05:58.875 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 255 06/18/2026 04:05:58.875 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 06/18/2026 04:05:58.875 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 06/18/2026 04:05:58.875 7fbdb01b2f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/18/2026 04:05:58.875 7fbdb01b2f40 [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=1674122441, session_epoch=6322, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:58.876 7fbdb01b2f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6340 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1674122441, session_epoch=6322, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:58.876 7fbdb01b2f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255993.089844, idle connection 194988.000000, request 304999.936581 06/18/2026 04:05:58.876 7fbdb01b2f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 255992.534912, idle connection 194988.000000, request 304999.392033 06/18/2026 04:05:58.917 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 1340 06/18/2026 04:05:58.918 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 06/18/2026 04:05:58.918 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)]) 06/18/2026 04:05:58.918 7fbdb01b2e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:58.918 7fbdb01b2e00 [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=683819233, session_epoch=6512, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:58.918 7fbdb01b2e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 6535 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=683819233, session_epoch=6512, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:58.919 7fbdb01b2e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 253842.450439, idle connection 190990.000000, request 304999.919653 06/18/2026 04:05:58.919 7fbdaf3dd220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256260.218750, idle connection 194943.000000, request 304397.030115 06/18/2026 04:05:58.919 7fbdb01b2e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 253841.798584, idle connection 190990.000000, request 304999.292612 06/18/2026 04:05:58.920 7fbdaf3dd220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6547 06/18/2026 04:05:58.920 7fbdaf3dd220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:58.920 7fbdaf3dd220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6547 (603.8477420806885 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=515211984, topics=[]) 06/18/2026 04:05:58.920 7fbdaf3dd220 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 515211984 with 0 response partitions (1 implied) 06/18/2026 04:05:58.966 7fbdb13b92c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254861.662354, idle connection 432335.000000, request 304398.081541 06/18/2026 04:05:58.967 7fbdb13b92c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6793 06/18/2026 04:05:58.967 7fbdb13b92c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:58.967 7fbdb13b92c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6793 (602.6420593261719 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1321523926, topics=[]) 06/18/2026 04:05:58.967 7fbdb13b92c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1321523926 with 0 response partitions (1 implied) 06/18/2026 04:05:59.013 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 425 06/18/2026 04:05:59.013 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 06/18/2026 04:05:59.014 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 06/18/2026 04:05:59.014 7fbdb13b9860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/18/2026 04:05:59.014 7fbdb13b9860 [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=1380226864, session_epoch=6349, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:59.014 7fbdb13b9860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6359 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1380226864, session_epoch=6349, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:59.014 7fbdb13b9860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254861.612061, idle connection 193853.000000, request 304999.921799 06/18/2026 04:05:59.015 7fbdb13b9860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254860.785645, idle connection 193853.000000, request 304999.107838 06/18/2026 04:05:59.027 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 4877 06/18/2026 04:05:59.027 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 06/18/2026 04:05:59.027 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 06/18/2026 04:05:59.028 7fbdb13b97c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/18/2026 04:05:59.028 7fbdb13b97c0 [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=2025868759, session_epoch=7105, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:59.028 7fbdb13b97c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 7125 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2025868759, session_epoch=7105, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:59.028 7fbdb13b97c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 253231.657471, idle connection 431021.000000, request 304999.941826 06/18/2026 04:05:59.029 7fbdb13b97c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 253231.007568, idle connection 431020.000000, request 304999.302149 06/18/2026 04:05:59.032 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 654 06/18/2026 04:05:59.032 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 06/18/2026 04:05:59.032 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 06/18/2026 04:05:59.032 7fbdb13b99a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 06/18/2026 04:05:59.033 7fbdb13b99a0 [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=2047323638, session_epoch=6421, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:59.033 7fbdb13b99a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Request 6435 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2047323638, session_epoch=6421, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:59.033 7fbdb13b99a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257774.591797, idle connection 195017.000000, request 304999.947309 06/18/2026 04:05:59.033 7fbdb13b99a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 257774.124756, idle connection 195016.000000, request 304999.486208 06/18/2026 04:05:59.090 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 250717.952148, idle connection 189531.000000, request 304398.528814 06/18/2026 04:05:59.091 7fbdaedf7720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9958 06/18/2026 04:05:59.091 7fbdaedf7720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:59.091 7fbdaedf7720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 9958 (602.0355224609375 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=464343197, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=53782, last_stable_offset=53782, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xd2\x15\x00\x00\x01\x12\x00\x00\x00\x00\x02\x8e`1g\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\xbe\x03\x00\x00\x00\x80\x03ObjectConfigDatabaseInfo:cn-jenk...')])]) 06/18/2026 04:05:59.091 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 464343197 with 1 response partitions (0 implied) 06/18/2026 04:05:59.091 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 286 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 53781 06/18/2026 04:05:59.091 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 53781 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 06/18/2026 04:05:59.092 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 53782 (leader epoch 0) 06/18/2026 04:05:59.143 7fbdb01b2cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254230.163330, idle connection 431622.000000, request 304398.095369 06/18/2026 04:05:59.143 7fbdb01b2cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6327 06/18/2026 04:05:59.144 7fbdb01b2cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:59.144 7fbdb01b2cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 6327 (602.6313304901123 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1059026835, topics=[]) 06/18/2026 04:05:59.144 7fbdb01b2cc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1059026835 with 0 response partitions (1 implied) 06/18/2026 04:05:59.144 7fbdb13b9900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254249.792480, idle connection 68650.000000, request 304397.623777 06/18/2026 04:05:59.144 7fbdb13b9900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6386 06/18/2026 04:05:59.144 7fbdb13b9900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:59.145 7fbdb13b9900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Response 6386 (602.7398109436035 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1677588942, topics=[]) 06/18/2026 04:05:59.145 7fbdb13b9900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1677588942 with 0 response partitions (1 implied) 06/18/2026 04:05:59.185 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 505 06/18/2026 04:05:59.185 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 06/18/2026 04:05:59.186 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 06/18/2026 04:05:59.186 7fbdb13b95e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 06/18/2026 04:05:59.186 7fbdb13b95e0 [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=1098554015, session_epoch=6360, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:59.186 7fbdb13b95e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.27', 9092)]>: Request 6372 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1098554015, session_epoch=6360, topics=[], forgotten_topics_data=[]) 06/18/2026 04:05:59.186 7fbdb13b95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254854.716553, idle connection 193849.000000, request 304999.932528 06/18/2026 04:05:59.187 7fbdb13b95e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 254854.021729, idle connection 193849.000000, request 304999.244213 06/18/2026 04:05:59.192 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 53782 06/18/2026 04:05:59.192 7fbdaedf7720 [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/18/2026 04:05:59.192 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 06/18/2026 04:05:59.192 7fbdaedf7720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 06/18/2026 04:05:59.193 7fbdaedf7720 [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=464343197, session_epoch=9948, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=53782, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/18/2026 04:05:59.193 7fbdaedf7720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 9959 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=464343197, session_epoch=9948, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=53782, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 06/18/2026 04:05:59.193 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 250615.107910, idle connection 189428.000000, request 304999.921083 06/18/2026 04:05:59.194 7fbdaedf7720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 250614.520264, idle connection 189428.000000, request 304999.344349 06/18/2026 04:05:59.236 7fbdb13b94a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 256659.099365, idle connection 133554.000000, request 304398.991108 06/18/2026 04:05:59.236 7fbdb13b94a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 6331 06/18/2026 04:05:59.236 7fbdb13b94a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 06/18/2026 04:05:59.236 7fbdb13b94a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.23', 9092)]>: Response 6331 (601.5462875366211 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=206808669, topics=[]) 06/18/2026 04:05:59.236 7fbdb13b94a0 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 206808669 with 0 response partitions (1 implied)