01/15/2026 04:48:33.054 7fab907fe360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 01/15/2026 04:48:33.055 7fab907fe360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 01/15/2026 04:48:33.055 7fab907fe360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/15/2026 04:48:33.055 7fab907fe360 [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=783094940, session_epoch=8281, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:33.055 7fab907fe360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 8300 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=783094940, session_epoch=8281, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:33.055 7fab907fe360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 211584.158691, idle connection 87240.000000, request 304999.938488 01/15/2026 04:48:33.056 7fab907fe360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 211583.287842, idle connection 87240.000000, request 304999.072552 01/15/2026 04:48:33.208 7fab907fe9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 4028 01/15/2026 04:48:33.208 7fab907fe9a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 01/15/2026 04:48:33.208 7fab907fe9a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 01/15/2026 04:48:33.208 7fab907fe9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/15/2026 04:48:33.208 7fab907fe9a0 [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=947551217, session_epoch=8555, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:33.209 7fab907fe9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 8573 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=947551217, session_epoch=8555, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:33.209 7fab907fe9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 211103.809570, idle connection 85790.000000, request 304999.941111 01/15/2026 04:48:33.210 7fab907fe9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 211102.281250, idle connection 85788.000000, request 304998.420715 01/15/2026 04:48:33.222 7fab8f1c67c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209773.194824, idle connection 387633.000000, request 304398.616791 01/15/2026 04:48:33.222 7fab8f1c67c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 13912 01/15/2026 04:48:33.222 7fab8f1c67c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/15/2026 04:48:33.223 7fab8f1c67c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 13912 (601.9995212554932 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2142303246, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=60553, last_stable_offset=60553, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xec\x88\x00\x00\x01\x0f\x00\x00\x00\x00\x02\x0e\x8a\x91M\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\xb8\x03\x00\x00\x00\xfa\x02ObjectAnalyticsSNMPInfo:cn-jenki...')])]) 01/15/2026 04:48:33.223 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2142303246 with 1 response partitions (0 implied) 01/15/2026 04:48:33.223 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 283 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 60552 01/15/2026 04:48:33.223 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 60552 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 01/15/2026 04:48:33.224 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 60553 (leader epoch 0) 01/15/2026 04:48:33.297 7fab907fe0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 574 01/15/2026 04:48:33.297 7fab907fe0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 01/15/2026 04:48:33.297 7fab907fe0e0 [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)]) 01/15/2026 04:48:33.297 7fab907fe0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/15/2026 04:48:33.298 7fab907fe0e0 [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=495162881, session_epoch=7891, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:33.298 7fab907fe0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 7907 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=495162881, session_epoch=7891, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:33.298 7fab907fe0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 216202.654541, idle connection 91866.000000, request 304999.915838 01/15/2026 04:48:33.299 7fab907fe0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 216201.956543, idle connection 91865.000000, request 304999.228477 01/15/2026 04:48:33.319 7fab907adea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 267 01/15/2026 04:48:33.319 7fab907adea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 01/15/2026 04:48:33.320 7fab907adea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 01/15/2026 04:48:33.320 7fab907adea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 01/15/2026 04:48:33.320 7fab907adea0 [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=935193381, session_epoch=7852, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:33.320 7fab907adea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7866 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=935193381, session_epoch=7852, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:33.320 7fab907adea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 215082.176514, idle connection 153652.000000, request 304999.917507 01/15/2026 04:48:33.321 7fab907adea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 215081.437988, idle connection 153652.000000, request 304999.134779 01/15/2026 04:48:33.324 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 60553 01/15/2026 04:48:33.324 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 01/15/2026 04:48:33.324 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 01/15/2026 04:48:33.324 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/15/2026 04:48:33.325 7fab8f1c67c0 [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=2142303246, session_epoch=13895, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=60553, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/15/2026 04:48:33.325 7fab8f1c67c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 13913 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2142303246, session_epoch=13895, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=60553, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/15/2026 04:48:33.325 7fab8f1c67c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209670.158203, idle connection 387530.000000, request 304999.944925 01/15/2026 04:48:33.325 7fab8f1c67c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209669.739990, idle connection 387530.000000, request 304999.531031 01/15/2026 04:48:33.417 7fab907fee00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 3671 01/15/2026 04:48:33.417 7fab907fee00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 01/15/2026 04:48:33.417 7fab907fee00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 01/15/2026 04:48:33.417 7fab907fee00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 01/15/2026 04:48:33.418 7fab907fee00 [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=1692398626, session_epoch=8334, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:33.418 7fab907fee00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 8355 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1692398626, session_epoch=8334, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:33.418 7fab907fee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209016.047119, idle connection 386930.000000, request 304999.932051 01/15/2026 04:48:33.418 7fab907fee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209015.552246, idle connection 386929.000000, request 304999.446630 01/15/2026 04:48:33.507 7fab907fe180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 214342.291992, idle connection 153673.000000, request 304397.136211 01/15/2026 04:48:33.508 7fab907fe180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7884 01/15/2026 04:48:33.508 7fab907fe180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/15/2026 04:48:33.508 7fab907fe180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.73', 9092)]>: Response 7884 (603.7631034851074 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=674095731, topics=[]) 01/15/2026 04:48:33.508 7fab907fe180 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 674095731 with 0 response partitions (1 implied) 01/15/2026 04:48:33.509 7fab907fecc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208457.296143, idle connection 147751.000000, request 304396.738768 01/15/2026 04:48:33.509 7fab907fecc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8684 01/15/2026 04:48:33.509 7fab907fecc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/15/2026 04:48:33.509 7fab907fecc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 8684 (603.7874221801758 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1444722118, topics=[(topics='-uve-topic-22', partitions=[(partition=0, error_code=0, highwater_offset=4900, last_stable_offset=4900, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x13#\x00\x00\x00\xfd\x00\x00\x00\x00\x02\xb7\xd7\xb7\xdc\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\x94\x03\x00\x00\x00\xd6\x02ObjectVNTable:default-domain:def...')])]) 01/15/2026 04:48:33.510 7fab907fecc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1444722118 with 1 response partitions (0 implied) 01/15/2026 04:48:33.510 7fab907fecc0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 265 bytes of data for partition TopicPartition(topic='-uve-topic-22', partition=0) with offset 4899 01/15/2026 04:48:33.510 7fab907fecc0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4899 for assigned partition TopicPartition(topic='-uve-topic-22', partition=0) 01/15/2026 04:48:33.510 7fab907fecc0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-22', partition=0) to 4900 (leader epoch 0) 01/15/2026 04:48:33.553 7fab907ade00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 364 01/15/2026 04:48:33.553 7fab907ade00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 01/15/2026 04:48:33.553 7fab907ade00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 01/15/2026 04:48:33.553 7fab907ade00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/15/2026 04:48:33.553 7fab907ade00 [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=237923601, session_epoch=7898, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:33.554 7fab907ade00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 7910 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=237923601, session_epoch=7898, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:33.554 7fab907ade00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 213690.097412, idle connection 152209.000000, request 304999.931812 01/15/2026 04:48:33.554 7fab907ade00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 213689.578857, idle connection 152208.000000, request 304999.422550 01/15/2026 04:48:33.556 7fab907fe7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 446 01/15/2026 04:48:33.556 7fab907fe7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 01/15/2026 04:48:33.556 7fab907fe7c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)]) 01/15/2026 04:48:33.556 7fab907fe7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 01/15/2026 04:48:33.556 7fab907fe7c0 [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=1302151640, session_epoch=7862, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:33.556 7fab907fe7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7874 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1302151640, session_epoch=7862, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:33.557 7fab907fe7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 214952.076416, idle connection 153769.000000, request 304999.951601 01/15/2026 04:48:33.557 7fab907fe7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 214951.700439, idle connection 153769.000000, request 304999.579430 01/15/2026 04:48:33.567 7fab907fe720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 211248.748047, idle connection 148771.000000, request 304398.728609 01/15/2026 04:48:33.567 7fab907fe720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8311 01/15/2026 04:48:33.567 7fab907fe720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/15/2026 04:48:33.568 7fab907fe720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.73', 9092)]>: Response 8311 (601.8321514129639 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=980292769, topics=[]) 01/15/2026 04:48:33.568 7fab907fe720 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 980292769 with 0 response partitions (1 implied) 01/15/2026 04:48:33.611 7fab907fecc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 4900 01/15/2026 04:48:33.611 7fab907fecc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 01/15/2026 04:48:33.611 7fab907fecc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered {TopicPartition(topic='-uve-topic-22', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 01/15/2026 04:48:33.611 7fab907fecc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 01/15/2026 04:48:33.611 7fab907fecc0 [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=1444722118, session_epoch=8673, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4900, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/15/2026 04:48:33.612 7fab907fecc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 8685 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1444722118, session_epoch=8673, topics=[(topic='-uve-topic-22', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4900, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/15/2026 04:48:33.612 7fab907fecc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208353.986328, idle connection 147647.000000, request 304999.908686 01/15/2026 04:48:33.613 7fab907fecc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208353.334961, idle connection 147647.000000, request 304999.271154 01/15/2026 04:48:33.657 7fab907fe360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210982.249756, idle connection 86638.000000, request 304398.028374 01/15/2026 04:48:33.658 7fab907fe360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8300 01/15/2026 04:48:33.658 7fab907fe360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/15/2026 04:48:33.658 7fab907fe360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 8300 (602.9961109161377 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=783094940, topics=[]) 01/15/2026 04:48:33.659 7fab907fe360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 783094940 with 0 response partitions (1 implied) 01/15/2026 04:48:33.811 7fab907fe9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210501.049316, idle connection 85187.000000, request 304397.177696 01/15/2026 04:48:33.812 7fab907fe9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8573 01/15/2026 04:48:33.812 7fab907fe9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/15/2026 04:48:33.812 7fab907fe9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 8573 (603.5051345825195 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=947551217, topics=[]) 01/15/2026 04:48:33.812 7fab907fe9a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 947551217 with 0 response partitions (1 implied) 01/15/2026 04:48:33.899 7fab907fe0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 215601.183350, idle connection 91264.000000, request 304398.449659 01/15/2026 04:48:33.900 7fab907fe0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7907 01/15/2026 04:48:33.900 7fab907fe0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/15/2026 04:48:33.900 7fab907fe0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 7907 (602.4699211120605 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=495162881, topics=[]) 01/15/2026 04:48:33.901 7fab907fe0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 495162881 with 0 response partitions (1 implied) 01/15/2026 04:48:33.922 7fab907adea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 214480.729004, idle connection 153051.000000, request 304398.478031 01/15/2026 04:48:33.922 7fab907adea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7866 01/15/2026 04:48:33.922 7fab907adea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/15/2026 04:48:33.922 7fab907adea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7866 (602.1068096160889 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=935193381, topics=[]) 01/15/2026 04:48:33.923 7fab907adea0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 935193381 with 0 response partitions (1 implied) 01/15/2026 04:48:33.926 7fab8f1c67c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209069.317627, idle connection 386929.000000, request 304399.102211 01/15/2026 04:48:33.926 7fab8f1c67c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 13913 01/15/2026 04:48:33.926 7fab8f1c67c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/15/2026 04:48:33.926 7fab8f1c67c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 13913 (601.475715637207 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2142303246, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=60555, last_stable_offset=60555, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xec\x89\x00\x00\x01\x10\x00\x00\x00\x00\x02\x1f\x99\x89F\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\xba\x03\x00\x00\x00\xfc\x02ObjectAnalyticsSNMPInfo:cn-jenki...')])]) 01/15/2026 04:48:33.927 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2142303246 with 1 response partitions (0 implied) 01/15/2026 04:48:33.927 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 557 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 60553 01/15/2026 04:48:33.927 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 60553 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 01/15/2026 04:48:33.927 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 60555 (leader epoch 0) 01/15/2026 04:48:34.019 7fab907fee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208414.962402, idle connection 386329.000000, request 304398.848057 01/15/2026 04:48:34.020 7fab907fee00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8355 01/15/2026 04:48:34.020 7fab907fee00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/15/2026 04:48:34.020 7fab907fee00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 8355 (601.9046306610107 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1692398626, topics=[]) 01/15/2026 04:48:34.020 7fab907fee00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1692398626 with 0 response partitions (1 implied) 01/15/2026 04:48:34.028 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 60555 01/15/2026 04:48:34.029 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 01/15/2026 04:48:34.029 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 01/15/2026 04:48:34.029 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/15/2026 04:48:34.029 7fab8f1c67c0 [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=2142303246, session_epoch=13896, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=60555, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/15/2026 04:48:34.029 7fab8f1c67c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 13914 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2142303246, session_epoch=13896, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=60555, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/15/2026 04:48:34.030 7fab8f1c67c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208965.570801, idle connection 386826.000000, request 304999.917507 01/15/2026 04:48:34.030 7fab8f1c67c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208965.024170, idle connection 386825.000000, request 304999.383926 01/15/2026 04:48:34.109 7fab907fe180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 333 01/15/2026 04:48:34.109 7fab907fe180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 01/15/2026 04:48:34.109 7fab907fe180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 01/15/2026 04:48:34.109 7fab907fe180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 01/15/2026 04:48:34.110 7fab907fe180 [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=674095731, session_epoch=7867, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:34.110 7fab907fe180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.73', 9092)]>: Request 7885 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=674095731, session_epoch=7867, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:34.110 7fab907fe180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 213739.482422, idle connection 153071.000000, request 304999.915123 01/15/2026 04:48:34.110 7fab907fe180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 213738.990723, idle connection 153070.000000, request 304999.438047 01/15/2026 04:48:34.155 7fab907ade00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 213088.927979, idle connection 151607.000000, request 304398.761749 01/15/2026 04:48:34.156 7fab907ade00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7910 01/15/2026 04:48:34.156 7fab907ade00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/15/2026 04:48:34.156 7fab907ade00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 7910 (601.8974781036377 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=237923601, topics=[]) 01/15/2026 04:48:34.156 7fab907ade00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 237923601 with 0 response partitions (1 implied) 01/15/2026 04:48:34.159 7fab907fe7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 214349.552002, idle connection 153167.000000, request 304397.423267 01/15/2026 04:48:34.159 7fab907fe7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7874 01/15/2026 04:48:34.160 7fab907fe7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/15/2026 04:48:34.160 7fab907fe7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7874 (603.1153202056885 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1302151640, topics=[]) 01/15/2026 04:48:34.160 7fab907fe7c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1302151640 with 0 response partitions (1 implied) 01/15/2026 04:48:34.168 7fab907fe720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 3211 01/15/2026 04:48:34.168 7fab907fe720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 01/15/2026 04:48:34.168 7fab907fe720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 01/15/2026 04:48:34.169 7fab907fe720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 01/15/2026 04:48:34.169 7fab907fe720 [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=980292769, session_epoch=8290, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:34.169 7fab907fe720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.73', 9092)]>: Request 8312 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=980292769, session_epoch=8290, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:34.169 7fab907fe720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210646.399170, idle connection 148169.000000, request 304999.922991 01/15/2026 04:48:34.170 7fab907fe720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210645.793457, idle connection 148168.000000, request 304999.323845 01/15/2026 04:48:34.214 7fab907fecc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207752.436035, idle connection 147046.000000, request 304398.368597 01/15/2026 04:48:34.214 7fab907fecc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8685 01/15/2026 04:48:34.214 7fab907fecc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/15/2026 04:48:34.214 7fab907fecc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 8685 (602.2052764892578 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1444722118, topics=[]) 01/15/2026 04:48:34.214 7fab907fecc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1444722118 with 0 response partitions (1 implied) 01/15/2026 04:48:34.259 7fab907fe360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 2933 01/15/2026 04:48:34.260 7fab907fe360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 01/15/2026 04:48:34.260 7fab907fe360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 01/15/2026 04:48:34.260 7fab907fe360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/15/2026 04:48:34.260 7fab907fe360 [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=783094940, session_epoch=8282, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:34.260 7fab907fe360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 8301 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=783094940, session_epoch=8282, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:34.261 7fab907fe360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210378.995605, idle connection 86035.000000, request 304999.911308 01/15/2026 04:48:34.262 7fab907fe360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210378.076416, idle connection 86034.000000, request 304999.003887 01/15/2026 04:48:34.413 7fab907fe9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 4028 01/15/2026 04:48:34.413 7fab907fe9a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 01/15/2026 04:48:34.413 7fab907fe9a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 01/15/2026 04:48:34.413 7fab907fe9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/15/2026 04:48:34.413 7fab907fe9a0 [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=947551217, session_epoch=8556, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:34.414 7fab907fe9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 8574 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=947551217, session_epoch=8556, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:34.414 7fab907fe9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209898.674072, idle connection 84585.000000, request 304999.925375 01/15/2026 04:48:34.414 7fab907fe9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209898.114746, idle connection 84584.000000, request 304999.380350 01/15/2026 04:48:34.501 7fab907fe0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 574 01/15/2026 04:48:34.502 7fab907fe0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 01/15/2026 04:48:34.502 7fab907fe0e0 [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)]) 01/15/2026 04:48:34.502 7fab907fe0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/15/2026 04:48:34.502 7fab907fe0e0 [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=495162881, session_epoch=7892, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:34.502 7fab907fe0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 7908 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=495162881, session_epoch=7892, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:34.502 7fab907fe0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 214998.225098, idle connection 90661.000000, request 304999.899387 01/15/2026 04:48:34.503 7fab907fe0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 214997.522949, idle connection 90661.000000, request 304999.225378 01/15/2026 04:48:34.524 7fab907adea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 267 01/15/2026 04:48:34.524 7fab907adea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 01/15/2026 04:48:34.524 7fab907adea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 01/15/2026 04:48:34.524 7fab907adea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 01/15/2026 04:48:34.525 7fab907adea0 [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=935193381, session_epoch=7853, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:34.525 7fab907adea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7867 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=935193381, session_epoch=7853, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:34.525 7fab907adea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 213877.566406, idle connection 152448.000000, request 304999.937296 01/15/2026 04:48:34.526 7fab907adea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 213876.977295, idle connection 152447.000000, request 304999.354362 01/15/2026 04:48:34.621 7fab907fee00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 3671 01/15/2026 04:48:34.621 7fab907fee00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 01/15/2026 04:48:34.621 7fab907fee00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 01/15/2026 04:48:34.621 7fab907fee00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 01/15/2026 04:48:34.621 7fab907fee00 [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=1692398626, session_epoch=8335, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:34.621 7fab907fee00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 8356 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1692398626, session_epoch=8335, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:34.621 7fab907fee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207812.532715, idle connection 385726.000000, request 304999.929190 01/15/2026 04:48:34.622 7fab907fee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207812.036621, idle connection 385726.000000, request 304999.440670 01/15/2026 04:48:34.631 7fab8f1c67c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208364.320801, idle connection 386224.000000, request 304398.677588 01/15/2026 04:48:34.631 7fab8f1c67c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 13914 01/15/2026 04:48:34.631 7fab8f1c67c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/15/2026 04:48:34.631 7fab8f1c67c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 13914 (601.9144058227539 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2142303246, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=60556, last_stable_offset=60556, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xec\x8b\x00\x00\x01\x05\x00\x00\x00\x00\x025i\x9e\x1f\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\xa4\x03\x00\x00\x00\xe6\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 01/15/2026 04:48:34.632 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2142303246 with 1 response partitions (0 implied) 01/15/2026 04:48:34.632 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 273 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 60555 01/15/2026 04:48:34.632 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 60555 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 01/15/2026 04:48:34.632 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 60556 (leader epoch 0) 01/15/2026 04:48:34.713 7fab907fe180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 213136.266846, idle connection 152467.000000, request 304396.708012 01/15/2026 04:48:34.714 7fab907fe180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7885 01/15/2026 04:48:34.714 7fab907fe180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/15/2026 04:48:34.714 7fab907fe180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.73', 9092)]>: Response 7885 (604.2139530181885 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=674095731, topics=[]) 01/15/2026 04:48:34.714 7fab907fe180 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 674095731 with 0 response partitions (1 implied) 01/15/2026 04:48:34.733 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 60556 01/15/2026 04:48:34.733 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 01/15/2026 04:48:34.733 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 01/15/2026 04:48:34.733 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/15/2026 04:48:34.733 7fab8f1c67c0 [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=2142303246, session_epoch=13897, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=60556, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/15/2026 04:48:34.734 7fab8f1c67c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 13915 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2142303246, session_epoch=13897, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=60556, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/15/2026 04:48:34.734 7fab8f1c67c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208261.406982, idle connection 386121.000000, request 304999.934196 01/15/2026 04:48:34.734 7fab8f1c67c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208260.880371, idle connection 386121.000000, request 304999.418736 01/15/2026 04:48:34.757 7fab907ade00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 364 01/15/2026 04:48:34.757 7fab907ade00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 01/15/2026 04:48:34.757 7fab907ade00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 01/15/2026 04:48:34.757 7fab907ade00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/15/2026 04:48:34.757 7fab907ade00 [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=237923601, session_epoch=7899, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:34.757 7fab907ade00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 7911 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=237923601, session_epoch=7899, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:34.758 7fab907ade00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 212486.382324, idle connection 151005.000000, request 304999.930620 01/15/2026 04:48:34.758 7fab907ade00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 212485.749268, idle connection 151004.000000, request 304999.308586 01/15/2026 04:48:34.761 7fab907fe7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 446 01/15/2026 04:48:34.761 7fab907fe7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 01/15/2026 04:48:34.761 7fab907fe7c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)]) 01/15/2026 04:48:34.761 7fab907fe7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 01/15/2026 04:48:34.762 7fab907fe7c0 [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=1302151640, session_epoch=7863, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:34.762 7fab907fe7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 7875 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1302151640, session_epoch=7863, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:34.762 7fab907fe7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 213746.909424, idle connection 152564.000000, request 304999.948740 01/15/2026 04:48:34.762 7fab907fe7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 213746.524658, idle connection 152564.000000, request 304999.567032 01/15/2026 04:48:34.771 7fab907fe720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210045.071045, idle connection 147567.000000, request 304398.461580 01/15/2026 04:48:34.771 7fab907fe720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8312 01/15/2026 04:48:34.771 7fab907fe720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/15/2026 04:48:34.771 7fab907fe720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.73', 9092)]>: Response 8312 (602.125883102417 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=980292769, topics=[]) 01/15/2026 04:48:34.772 7fab907fe720 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 980292769 with 0 response partitions (1 implied) 01/15/2026 04:48:34.815 7fab907fecc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 4900 01/15/2026 04:48:34.815 7fab907fecc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 01/15/2026 04:48:34.815 7fab907fecc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 01/15/2026 04:48:34.815 7fab907fecc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2 01/15/2026 04:48:34.815 7fab907fecc0 [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=1444722118, session_epoch=8674, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:34.816 7fab907fecc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Request 8686 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1444722118, session_epoch=8674, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:34.816 7fab907fecc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207150.294434, idle connection 146444.000000, request 304999.938726 01/15/2026 04:48:34.816 7fab907fecc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207149.818115, idle connection 146443.000000, request 304999.473572 01/15/2026 04:48:34.862 7fab907fe360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209777.405762, idle connection 85434.000000, request 304398.331881 01/15/2026 04:48:34.863 7fab907fe360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8301 01/15/2026 04:48:34.863 7fab907fe360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/15/2026 04:48:34.863 7fab907fe360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 8301 (602.3068428039551 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=783094940, topics=[]) 01/15/2026 04:48:34.863 7fab907fe360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 783094940 with 0 response partitions (1 implied) 01/15/2026 04:48:35.015 7fab907fe9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209297.431641, idle connection 83983.000000, request 304398.686886 01/15/2026 04:48:35.016 7fab907fe9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8574 01/15/2026 04:48:35.016 7fab907fe9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/15/2026 04:48:35.016 7fab907fe9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 8574 (601.9504070281982 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=947551217, topics=[]) 01/15/2026 04:48:35.016 7fab907fe9a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 947551217 with 0 response partitions (1 implied) 01/15/2026 04:48:35.104 7fab907fe0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 214396.879395, idle connection 90060.000000, request 304398.571491 01/15/2026 04:48:35.104 7fab907fe0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7908 01/15/2026 04:48:35.104 7fab907fe0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/15/2026 04:48:35.105 7fab907fe0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 7908 (602.1616458892822 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=495162881, topics=[]) 01/15/2026 04:48:35.105 7fab907fe0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 495162881 with 0 response partitions (1 implied) 01/15/2026 04:48:35.127 7fab907adea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 213275.531738, idle connection 151846.000000, request 304397.903204 01/15/2026 04:48:35.127 7fab907adea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7867 01/15/2026 04:48:35.127 7fab907adea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/15/2026 04:48:35.128 7fab907adea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7867 (602.6983261108398 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=935193381, topics=[]) 01/15/2026 04:48:35.128 7fab907adea0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 935193381 with 0 response partitions (1 implied) 01/15/2026 04:48:35.223 7fab907fee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207211.288086, idle connection 385125.000000, request 304398.683310 01/15/2026 04:48:35.223 7fab907fee00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8356 01/15/2026 04:48:35.223 7fab907fee00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/15/2026 04:48:35.223 7fab907fee00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 8356 (602.043628692627 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1692398626, topics=[]) 01/15/2026 04:48:35.224 7fab907fee00 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1692398626 with 0 response partitions (1 implied) 01/15/2026 04:48:35.315 7fab907fe180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 333 01/15/2026 04:48:35.315 7fab907fe180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 01/15/2026 04:48:35.315 7fab907fe180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 01/15/2026 04:48:35.316 7fab907fe180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 01/15/2026 04:48:35.316 7fab907fe180 [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=674095731, session_epoch=7868, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:35.316 7fab907fe180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.73', 9092)]>: Request 7886 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=674095731, session_epoch=7868, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:35.316 7fab907fe180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 212533.479492, idle connection 151865.000000, request 304999.936104 01/15/2026 04:48:35.317 7fab907fe180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 212532.890869, idle connection 151864.000000, request 304999.358177 01/15/2026 04:48:35.335 7fab8f1c67c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207660.190674, idle connection 385520.000000, request 304398.723602 01/15/2026 04:48:35.335 7fab8f1c67c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 13915 01/15/2026 04:48:35.336 7fab8f1c67c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/15/2026 04:48:35.336 7fab8f1c67c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 13915 (601.9699573516846 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2142303246, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=60557, last_stable_offset=60557, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\xec\x8c\x00\x00\x01\x10\x00\x00\x00\x00\x02Y\x8b\x1a\x84\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\xba\x03\x00\x00\x00\xfc\x02ObjectAnalyticsSNMPInfo:cn-jenki...')])]) 01/15/2026 04:48:35.336 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2142303246 with 1 response partitions (0 implied) 01/15/2026 04:48:35.336 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 284 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 60556 01/15/2026 04:48:35.336 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 60556 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 01/15/2026 04:48:35.336 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 60557 (leader epoch 0) 01/15/2026 04:48:35.359 7fab907ade00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 211885.020752, idle connection 150403.000000, request 304398.571491 01/15/2026 04:48:35.359 7fab907ade00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7911 01/15/2026 04:48:35.359 7fab907ade00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/15/2026 04:48:35.360 7fab907ade00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Response 7911 (601.9856929779053 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=237923601, topics=[]) 01/15/2026 04:48:35.360 7fab907ade00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 237923601 with 0 response partitions (1 implied) 01/15/2026 04:48:35.363 7fab907fe7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 213145.268311, idle connection 151962.000000, request 304398.303747 01/15/2026 04:48:35.364 7fab907fe7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7875 01/15/2026 04:48:35.364 7fab907fe7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/15/2026 04:48:35.364 7fab907fe7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 7875 (602.2076606750488 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1302151640, topics=[]) 01/15/2026 04:48:35.364 7fab907fe7c0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1302151640 with 0 response partitions (1 implied) 01/15/2026 04:48:35.372 7fab907fe720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 3211 01/15/2026 04:48:35.372 7fab907fe720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 01/15/2026 04:48:35.372 7fab907fe720 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 01/15/2026 04:48:35.372 7fab907fe720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3 01/15/2026 04:48:35.372 7fab907fe720 [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=980292769, session_epoch=8291, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:35.373 7fab907fe720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.73', 9092)]>: Request 8313 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=980292769, session_epoch=8291, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:35.373 7fab907fe720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209442.898193, idle connection 146965.000000, request 304999.942303 01/15/2026 04:48:35.373 7fab907fe720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209442.471191, idle connection 146965.000000, request 304999.523401 01/15/2026 04:48:35.417 7fab907fecc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206549.224609, idle connection 145843.000000, request 304398.868799 01/15/2026 04:48:35.417 7fab907fecc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8686 01/15/2026 04:48:35.417 7fab907fecc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/15/2026 04:48:35.418 7fab907fecc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.33', 9092)]>: Response 8686 (601.8481254577637 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1444722118, topics=[]) 01/15/2026 04:48:35.418 7fab907fecc0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1444722118 with 0 response partitions (1 implied) 01/15/2026 04:48:35.438 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 60557 01/15/2026 04:48:35.438 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 01/15/2026 04:48:35.438 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 01/15/2026 04:48:35.438 7fab8f1c67c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/15/2026 04:48:35.438 7fab8f1c67c0 [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=2142303246, session_epoch=13898, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=60557, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/15/2026 04:48:35.439 7fab8f1c67c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 13916 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2142303246, session_epoch=13898, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=60557, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/15/2026 04:48:35.439 7fab8f1c67c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207556.270996, idle connection 385416.000000, request 304999.925852 01/15/2026 04:48:35.439 7fab8f1c67c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207555.718994, idle connection 385416.000000, request 304999.388695 01/15/2026 04:48:35.464 7fab907fe360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 2933 01/15/2026 04:48:35.464 7fab907fe360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 01/15/2026 04:48:35.464 7fab907fe360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 01/15/2026 04:48:35.464 7fab907fe360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/15/2026 04:48:35.464 7fab907fe360 [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=783094940, session_epoch=8283, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:35.464 7fab907fe360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 8302 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=783094940, session_epoch=8283, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:35.465 7fab907fe360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209175.094238, idle connection 84831.000000, request 304999.905109 01/15/2026 04:48:35.465 7fab907fe360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209174.407471, idle connection 84831.000000, request 304999.237299 01/15/2026 04:48:35.616 7fab907fe9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 4028 01/15/2026 04:48:35.617 7fab907fe9a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 01/15/2026 04:48:35.617 7fab907fe9a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 01/15/2026 04:48:35.617 7fab907fe9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/15/2026 04:48:35.617 7fab907fe9a0 [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=947551217, session_epoch=8557, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:35.617 7fab907fe9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.242', 9092)]>: Request 8575 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=947551217, session_epoch=8557, topics=[], forgotten_topics_data=[]) 01/15/2026 04:48:35.617 7fab907fe9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208695.033203, idle connection 83381.000000, request 304999.916792 01/15/2026 04:48:35.618 7fab907fe9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208694.479980, idle connection 83380.000000, request 304999.375105