01/08/2026 02:01:22.758 7fd8ebf77cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=517327005, session_epoch=348, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:22.758 7fd8ebf77cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 351 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=517327005, session_epoch=348, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:22.758 7fd8ebf77cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206326.579346, idle connection 145422.000000, request 304999.937534 01/08/2026 02:01:22.759 7fd8ebf77cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206326.050781, idle connection 145421.000000, request 304999.418497 01/08/2026 02:01:22.771 7fd8eb639540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206397.546387, idle connection 144935.000000, request 304396.941900 01/08/2026 02:01:22.771 7fd8eb639540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 331 01/08/2026 02:01:22.771 7fd8eb639540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:22.772 7fd8eb639540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 331 (603.6553382873535 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1086826783, topics=[]) 01/08/2026 02:01:22.772 7fd8eb639540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1086826783 with 0 response partitions (1 implied) 01/08/2026 02:01:22.772 7fd8ea26ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205905.329834, idle connection 144889.000000, request 304396.518707 01/08/2026 02:01:22.772 7fd8ea26ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205875.486084, idle connection 144894.000000, request 304397.073507 01/08/2026 02:01:22.772 7fd8ea26ee00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 329 01/08/2026 02:01:22.772 7fd8ea26ee00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:22.772 7fd8ea26ee00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 329 (603.9443016052246 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=480896038, topics=[]) 01/08/2026 02:01:22.773 7fd8ea26ee00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 480896038 with 0 response partitions (1 implied) 01/08/2026 02:01:22.773 7fd8ea26ed60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 344 01/08/2026 02:01:22.773 7fd8ea26ed60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:22.773 7fd8ea26ed60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 344 (603.8463115692139 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=786968917, topics=[]) 01/08/2026 02:01:22.773 7fd8ea26ed60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 786968917 with 0 response partitions (1 implied) 01/08/2026 02:01:22.797 7fd8e9f6f900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205794.454346, idle connection 144856.000000, request 304395.231962 01/08/2026 02:01:22.797 7fd8e9f6f900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 495 01/08/2026 02:01:22.797 7fd8e9f6f900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:22.797 7fd8e9f6f900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 495 (605.2632331848145 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=215600143, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4126, last_stable_offset=4126, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x10\x1d\x00\x00\x01\x19\x00\x00\x00\x00\x02m\xaa\x9d\x91\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...')])]) 01/08/2026 02:01:22.797 7fd8e9f6f900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 215600143 with 1 response partitions (0 implied) 01/08/2026 02:01:22.797 7fd8e9f6f900 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 293 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 4125 01/08/2026 02:01:22.798 7fd8e9f6f900 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4125 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 01/08/2026 02:01:22.798 7fd8e9f6f900 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 4126 (leader epoch 0) 01/08/2026 02:01:22.854 7fd8eb6390e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205877.026367, idle connection 144840.000000, request 304396.323442 01/08/2026 02:01:22.854 7fd8eb6390e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 329 01/08/2026 02:01:22.854 7fd8eb6390e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:22.855 7fd8eb6390e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 329 (604.3272018432617 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=955933130, topics=[]) 01/08/2026 02:01:22.855 7fd8eb6390e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 955933130 with 0 response partitions (1 implied) 01/08/2026 02:01:22.855 7fd8e9f424a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205888.087158, idle connection 145034.000000, request 304396.053076 01/08/2026 02:01:22.855 7fd8e9f424a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 330 01/08/2026 02:01:22.855 7fd8e9f424a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:22.855 7fd8e9f424a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 330 (604.2752265930176 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=867673153, topics=[]) 01/08/2026 02:01:22.855 7fd8e9f424a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 867673153 with 0 response partitions (1 implied) 01/08/2026 02:01:22.856 7fd8eb639680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 53 01/08/2026 02:01:22.856 7fd8eb639680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 01/08/2026 02:01:22.856 7fd8eb639680 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)]) 01/08/2026 02:01:22.856 7fd8eb639680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:22.856 7fd8eb639680 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2133686535, session_epoch=341, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:22.856 7fd8eb639680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 344 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2133686535, session_epoch=341, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:22.856 7fd8eb639680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205763.171143, idle connection 145131.000000, request 304999.956846 01/08/2026 02:01:22.856 7fd8ea0239a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206030.190674, idle connection 144990.000000, request 304395.858765 01/08/2026 02:01:22.857 7fd8ea654ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206296.116699, idle connection 144958.000000, request 304396.390915 01/08/2026 02:01:22.857 7fd8ea0239a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 329 01/08/2026 02:01:22.857 7fd8ea0239a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:22.857 7fd8ea0239a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 329 (604.6125888824463 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=53370133, topics=[]) 01/08/2026 02:01:22.857 7fd8ea0239a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 53370133 with 0 response partitions (1 implied) 01/08/2026 02:01:22.857 7fd8ea654ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 332 01/08/2026 02:01:22.857 7fd8ea654ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:22.857 7fd8ea654ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 332 (604.4285297393799 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1793959720, topics=[]) 01/08/2026 02:01:22.858 7fd8ea654ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1793959720 with 0 response partitions (1 implied) 01/08/2026 02:01:22.858 7fd8eb639720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 37 01/08/2026 02:01:22.858 7fd8eb639720 [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/08/2026 02:01:22.858 7fd8eb639720 [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/08/2026 02:01:22.858 7fd8eb639720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:22.858 7fd8eb639720 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=322520549, session_epoch=335, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:22.858 7fd8eb639720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 338 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=322520549, session_epoch=335, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:22.858 7fd8eb639720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206880.500000, idle connection 145158.000000, request 304999.961138 01/08/2026 02:01:22.858 7fd8ea60f5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 38 01/08/2026 02:01:22.859 7fd8ea60f5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 01/08/2026 02:01:22.859 7fd8ea60f5e0 [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)]) 01/08/2026 02:01:22.859 7fd8ea60f5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:22.859 7fd8ea60f5e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1239416943, session_epoch=334, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:22.859 7fd8ea60f5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 337 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1239416943, session_epoch=334, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:22.859 7fd8ea60f5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206488.356201, idle connection 145068.000000, request 304999.961138 01/08/2026 02:01:22.859 7fd8eb639680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205760.047119, idle connection 145128.000000, request 304996.836185 01/08/2026 02:01:22.860 7fd8eb639720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206878.992432, idle connection 145157.000000, request 304998.456478 01/08/2026 02:01:22.860 7fd8ea60f5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206487.306396, idle connection 145067.000000, request 304998.914719 01/08/2026 02:01:22.870 7fd8eb639d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206810.577148, idle connection 145175.000000, request 304396.726847 01/08/2026 02:01:22.870 7fd8eb639d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 336 01/08/2026 02:01:22.870 7fd8eb639d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:22.870 7fd8eb639d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 336 (603.7545204162598 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=555761639, topics=[]) 01/08/2026 02:01:22.870 7fd8eb639d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 555761639 with 0 response partitions (1 implied) 01/08/2026 02:01:22.871 7fd8eb6395e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206079.773682, idle connection 144874.000000, request 304396.658659 01/08/2026 02:01:22.871 7fd8ebf77540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206900.767090, idle connection 145261.000000, request 304397.626877 01/08/2026 02:01:22.871 7fd8eb6395e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 330 01/08/2026 02:01:22.871 7fd8eb6395e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:22.871 7fd8eb6395e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 330 (603.8246154785156 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1376158528, topics=[]) 01/08/2026 02:01:22.871 7fd8eb6395e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1376158528 with 0 response partitions (1 implied) 01/08/2026 02:01:22.871 7fd8ebf77540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 367 01/08/2026 02:01:22.871 7fd8ebf77540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:22.872 7fd8ebf77540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 367 (603.240966796875 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1622962595, topics=[]) 01/08/2026 02:01:22.872 7fd8ebf77540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1622962595 with 0 response partitions (1 implied) 01/08/2026 02:01:22.897 7fd8ebf772c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206054.624756, idle connection 145326.000000, request 304398.864985 01/08/2026 02:01:22.898 7fd8ebf772c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 353 01/08/2026 02:01:22.898 7fd8ebf772c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:22.898 7fd8ebf772c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 353 (601.708173751831 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=684611967, topics=[]) 01/08/2026 02:01:22.898 7fd8ebf772c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 684611967 with 0 response partitions (1 implied) 01/08/2026 02:01:22.898 7fd8e9f6f900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4126 01/08/2026 02:01:22.899 7fd8e9f6f900 [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/08/2026 02:01:22.899 7fd8e9f6f900 [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/08/2026 02:01:22.899 7fd8e9f6f900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:22.899 7fd8e9f6f900 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=215600143, session_epoch=493, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4126, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/08/2026 02:01:22.899 7fd8e9f6f900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 496 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=215600143, session_epoch=493, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4126, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/08/2026 02:01:22.899 7fd8e9f6f900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205691.868164, idle connection 144754.000000, request 304999.953270 01/08/2026 02:01:22.900 7fd8e9f6f900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205691.449219, idle connection 144753.000000, request 304999.536753 01/08/2026 02:01:23.022 7fd8eb639ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206055.173828, idle connection 144986.000000, request 304397.971869 01/08/2026 02:01:23.022 7fd8eb639ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 338 01/08/2026 02:01:23.023 7fd8eb639ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:23.023 7fd8eb639ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 338 (602.6270389556885 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=235423344, topics=[]) 01/08/2026 02:01:23.023 7fd8eb639ea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 235423344 with 0 response partitions (1 implied) 01/08/2026 02:01:23.044 7fd8ebf770e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 290 01/08/2026 02:01:23.044 7fd8ebf770e0 [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/08/2026 02:01:23.044 7fd8ebf770e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 01/08/2026 02:01:23.044 7fd8ebf770e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:23.044 7fd8ebf770e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1609264503, session_epoch=357, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.044 7fd8ebf770e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 360 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1609264503, session_epoch=357, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.044 7fd8ebf770e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206781.293457, idle connection 145056.000000, request 304999.943495 01/08/2026 02:01:23.045 7fd8ebf770e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206780.819580, idle connection 145055.000000, request 304999.478579 01/08/2026 02:01:23.052 7fd8ebf77c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206784.853271, idle connection 145163.000000, request 304399.194002 01/08/2026 02:01:23.052 7fd8ebf77c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 348 01/08/2026 02:01:23.053 7fd8ebf77c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:23.053 7fd8ebf77c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 348 (601.2270450592041 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=899604297, topics=[]) 01/08/2026 02:01:23.053 7fd8ebf77c20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 899604297 with 0 response partitions (1 implied) 01/08/2026 02:01:23.064 7fd8ebf77400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 198 01/08/2026 02:01:23.064 7fd8ebf77400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 01/08/2026 02:01:23.064 7fd8ebf77400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 01/08/2026 02:01:23.064 7fd8ebf77400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:23.064 7fd8ebf77400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1950081189, session_epoch=347, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.064 7fd8ebf77400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 350 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1950081189, session_epoch=347, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.065 7fd8ebf77400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205905.487061, idle connection 145078.000000, request 304999.951601 01/08/2026 02:01:23.065 7fd8ebf77400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205905.057617, idle connection 145078.000000, request 304999.526739 01/08/2026 02:01:23.077 7fd8ebf777c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 157 01/08/2026 02:01:23.077 7fd8ebf777c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 01/08/2026 02:01:23.078 7fd8ebf777c0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 01/08/2026 02:01:23.078 7fd8ebf777c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:23.078 7fd8ebf777c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=4874832, session_epoch=353, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.078 7fd8ebf777c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 356 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=4874832, session_epoch=353, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.078 7fd8ebf777c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205782.845215, idle connection 145089.000000, request 304999.940634 01/08/2026 02:01:23.078 7fd8ebf777c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205782.430664, idle connection 145089.000000, request 304999.533892 01/08/2026 02:01:23.088 7fd8eb639860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 204 01/08/2026 02:01:23.088 7fd8eb639860 [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/08/2026 02:01:23.088 7fd8eb639860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-20', partition=0)]) 01/08/2026 02:01:23.088 7fd8eb639860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:23.088 7fd8eb639860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=980843328, session_epoch=364, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.088 7fd8eb639860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 367 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=980843328, session_epoch=364, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.088 7fd8eb639860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205897.345947, idle connection 144964.000000, request 304999.950409 01/08/2026 02:01:23.089 7fd8eb639860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205896.897949, idle connection 144964.000000, request 304999.505043 01/08/2026 02:01:23.123 7fd8ea023d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205946.078613, idle connection 144744.000000, request 304397.279978 01/08/2026 02:01:23.123 7fd8ea023d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 329 01/08/2026 02:01:23.123 7fd8ea023d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:23.123 7fd8ea023d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 329 (603.2123565673828 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=331045173, topics=[]) 01/08/2026 02:01:23.123 7fd8ea023d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 331045173 with 0 response partitions (1 implied) 01/08/2026 02:01:23.123 7fd8e9f42a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205948.053467, idle connection 144754.000000, request 304397.052765 01/08/2026 02:01:23.124 7fd8e9f42a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 329 01/08/2026 02:01:23.124 7fd8e9f42a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:23.124 7fd8e9f42a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 329 (603.2912731170654 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=568810886, topics=[]) 01/08/2026 02:01:23.124 7fd8e9f42a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 568810886 with 0 response partitions (1 implied) 01/08/2026 02:01:23.124 7fd8ea5f00e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206047.193359, idle connection 144813.000000, request 304397.488832 01/08/2026 02:01:23.124 7fd8ea023180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205949.596436, idle connection 144711.000000, request 304398.561716 01/08/2026 02:01:23.124 7fd8ea5f00e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 337 01/08/2026 02:01:23.125 7fd8ea5f00e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:23.125 7fd8ea5f00e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 337 (602.9682159423828 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1543064989, topics=[]) 01/08/2026 02:01:23.125 7fd8ea5f00e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1543064989 with 0 response partitions (1 implied) 01/08/2026 02:01:23.125 7fd8ea023180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 332 01/08/2026 02:01:23.125 7fd8ea023180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:23.125 7fd8ea023180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 332 (602.3430824279785 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1999726234, topics=[]) 01/08/2026 02:01:23.125 7fd8ea023180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1999726234 with 0 response partitions (1 implied) 01/08/2026 02:01:23.171 7fd8ebf77b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205796.340576, idle connection 145099.000000, request 304399.006844 01/08/2026 02:01:23.171 7fd8ebf77b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 342 01/08/2026 02:01:23.171 7fd8ebf77b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:23.171 7fd8ebf77b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 342 (601.520299911499 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1606196909, topics=[]) 01/08/2026 02:01:23.171 7fd8ebf77b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1606196909 with 0 response partitions (1 implied) 01/08/2026 02:01:23.172 7fd8eb639e00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 157 01/08/2026 02:01:23.172 7fd8eb639e00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 01/08/2026 02:01:23.172 7fd8eb639e00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)]) 01/08/2026 02:01:23.172 7fd8eb639e00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:23.172 7fd8eb639e00 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1250139762, session_epoch=350, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.172 7fd8eb639e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 353 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1250139762, session_epoch=350, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.173 7fd8eb639e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205788.761475, idle connection 144903.000000, request 304999.943256 01/08/2026 02:01:23.173 7fd8eb639e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205788.362549, idle connection 144903.000000, request 304999.547958 01/08/2026 02:01:23.195 7fd8ebf77180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206310.921387, idle connection 145071.000000, request 304399.040937 01/08/2026 02:01:23.195 7fd8ebf77180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 363 01/08/2026 02:01:23.195 7fd8ebf77180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:23.195 7fd8ebf77180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 363 (601.4487743377686 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1131630823, topics=[]) 01/08/2026 02:01:23.195 7fd8ebf77180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1131630823 with 0 response partitions (1 implied) 01/08/2026 02:01:23.219 7fd8eb639220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206549.702881, idle connection 144750.000000, request 304398.992062 01/08/2026 02:01:23.219 7fd8eb639220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 338 01/08/2026 02:01:23.219 7fd8eb639220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:23.219 7fd8eb639220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 338 (601.4862060546875 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1784376784, topics=[]) 01/08/2026 02:01:23.219 7fd8eb639220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1784376784 with 0 response partitions (1 implied) 01/08/2026 02:01:23.360 7fd8ebf77cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205725.033936, idle connection 144820.000000, request 304398.389816 01/08/2026 02:01:23.360 7fd8ebf77cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 351 01/08/2026 02:01:23.360 7fd8ebf77cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:23.360 7fd8ebf77cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 351 (602.2093296051025 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=517327005, topics=[]) 01/08/2026 02:01:23.361 7fd8ebf77cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 517327005 with 0 response partitions (1 implied) 01/08/2026 02:01:23.372 7fd8eb639540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 7 01/08/2026 02:01:23.372 7fd8eb639540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 01/08/2026 02:01:23.372 7fd8eb639540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 01/08/2026 02:01:23.372 7fd8eb639540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:23.372 7fd8eb639540 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1086826783, session_epoch=329, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.373 7fd8eb639540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 332 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1086826783, session_epoch=329, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.373 7fd8eb639540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205795.716797, idle connection 144333.000000, request 304999.945164 01/08/2026 02:01:23.373 7fd8ea26ee00 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 01/08/2026 02:01:23.373 7fd8ea26ee00 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 01/08/2026 02:01:23.373 7fd8ea26ee00 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)]) 01/08/2026 02:01:23.373 7fd8ea26ee00 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:23.373 7fd8ea26ee00 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=480896038, session_epoch=327, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.373 7fd8ea26ee00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 330 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=480896038, session_epoch=327, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.373 7fd8ea26ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205303.843018, idle connection 144288.000000, request 304999.959946 01/08/2026 02:01:23.374 7fd8eb639540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205794.548828, idle connection 144332.000000, request 304998.785973 01/08/2026 02:01:23.374 7fd8ea26ed60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 65 01/08/2026 02:01:23.374 7fd8ea26ed60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 01/08/2026 02:01:23.374 7fd8ea26ed60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 01/08/2026 02:01:23.374 7fd8ea26ed60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:23.374 7fd8ea26ed60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=786968917, session_epoch=342, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.374 7fd8ea26ed60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 345 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=786968917, session_epoch=342, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.375 7fd8ea26ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205273.037842, idle connection 144291.000000, request 304999.952078 01/08/2026 02:01:23.375 7fd8ea26ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205302.431641, idle connection 144286.000000, request 304998.552322 01/08/2026 02:01:23.375 7fd8ea26ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205272.347168, idle connection 144291.000000, request 304999.264479 01/08/2026 02:01:23.455 7fd8eb6390e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 01/08/2026 02:01:23.455 7fd8eb6390e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 01/08/2026 02:01:23.455 7fd8eb6390e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 01/08/2026 02:01:23.456 7fd8eb6390e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:23.456 7fd8eb6390e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=955933130, session_epoch=327, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.456 7fd8eb6390e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 330 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=955933130, session_epoch=327, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.456 7fd8eb6390e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205274.912598, idle connection 144238.000000, request 304999.939919 01/08/2026 02:01:23.456 7fd8e9f424a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 4 01/08/2026 02:01:23.456 7fd8e9f424a0 [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/08/2026 02:01:23.456 7fd8e9f424a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)]) 01/08/2026 02:01:23.456 7fd8e9f424a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:23.457 7fd8e9f424a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=867673153, session_epoch=328, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.457 7fd8e9f424a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 331 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=867673153, session_epoch=328, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.457 7fd8e9f424a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205286.292480, idle connection 144433.000000, request 304999.960184 01/08/2026 02:01:23.457 7fd8eb6390e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205273.724121, idle connection 144237.000000, request 304998.762131 01/08/2026 02:01:23.457 7fd8ea0239a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 0 01/08/2026 02:01:23.457 7fd8ea0239a0 [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/08/2026 02:01:23.457 7fd8ea0239a0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 01/08/2026 02:01:23.458 7fd8ea0239a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:23.458 7fd8ea0239a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=53370133, session_epoch=327, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.458 7fd8ea0239a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 330 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=53370133, session_epoch=327, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.458 7fd8ea0239a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205428.724609, idle connection 144388.000000, request 304999.961615 01/08/2026 02:01:23.458 7fd8e9f424a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205284.850830, idle connection 144431.000000, request 304998.522043 01/08/2026 02:01:23.458 7fd8ea654ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 9 01/08/2026 02:01:23.459 7fd8ea654ea0 [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/08/2026 02:01:23.459 7fd8ea654ea0 [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/08/2026 02:01:23.459 7fd8ea654ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:23.459 7fd8ea654ea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1793959720, session_epoch=330, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.459 7fd8ea654ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 333 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1793959720, session_epoch=330, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.459 7fd8ea654ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205693.685059, idle connection 144355.000000, request 304999.964952 01/08/2026 02:01:23.459 7fd8ea0239a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205427.331299, idle connection 144387.000000, request 304998.571396 01/08/2026 02:01:23.460 7fd8ea654ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205693.041504, idle connection 144355.000000, request 304999.323845 01/08/2026 02:01:23.460 7fd8eb639680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205159.089355, idle connection 144527.000000, request 304395.877361 01/08/2026 02:01:23.460 7fd8eb639680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 344 01/08/2026 02:01:23.461 7fd8eb639680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:23.461 7fd8eb639680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 344 (604.4921875 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2133686535, topics=[]) 01/08/2026 02:01:23.461 7fd8eb639680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2133686535 with 0 response partitions (1 implied) 01/08/2026 02:01:23.461 7fd8eb639720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206277.731201, idle connection 144555.000000, request 304397.192955 01/08/2026 02:01:23.461 7fd8ea60f5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205886.184082, idle connection 144465.000000, request 304397.792339 01/08/2026 02:01:23.461 7fd8eb639720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 338 01/08/2026 02:01:23.461 7fd8eb639720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:23.462 7fd8eb639720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 338 (603.3391952514648 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=322520549, topics=[]) 01/08/2026 02:01:23.462 7fd8eb639720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 322520549 with 0 response partitions (1 implied) 01/08/2026 02:01:23.462 7fd8ea60f5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 337 01/08/2026 02:01:23.462 7fd8ea60f5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:23.462 7fd8ea60f5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 337 (603.1599044799805 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1239416943, topics=[]) 01/08/2026 02:01:23.462 7fd8ea60f5e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1239416943 with 0 response partitions (1 implied) 01/08/2026 02:01:23.471 7fd8eb639d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 36 01/08/2026 02:01:23.471 7fd8eb639d60 [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/08/2026 02:01:23.471 7fd8eb639d60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)]) 01/08/2026 02:01:23.471 7fd8eb639d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:23.471 7fd8eb639d60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=555761639, session_epoch=334, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.471 7fd8eb639d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 337 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=555761639, session_epoch=334, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.471 7fd8eb639d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206209.094482, idle connection 144574.000000, request 304999.951124 01/08/2026 02:01:23.472 7fd8eb639d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206208.726318, idle connection 144573.000000, request 304999.586582 01/08/2026 02:01:23.472 7fd8eb6395e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 2 01/08/2026 02:01:23.472 7fd8eb6395e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 01/08/2026 02:01:23.472 7fd8eb6395e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 01/08/2026 02:01:23.472 7fd8eb6395e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:23.472 7fd8eb6395e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1376158528, session_epoch=328, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.472 7fd8eb6395e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 331 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1376158528, session_epoch=328, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.472 7fd8eb6395e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205478.097656, idle connection 144272.000000, request 304999.961615 01/08/2026 02:01:23.472 7fd8ebf77540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 244 01/08/2026 02:01:23.473 7fd8ebf77540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 01/08/2026 02:01:23.473 7fd8ebf77540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-23', partition=0)]) 01/08/2026 02:01:23.473 7fd8ebf77540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:23.473 7fd8ebf77540 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1622962595, session_epoch=365, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.473 7fd8ebf77540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 368 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1622962595, session_epoch=365, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.473 7fd8ebf77540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206298.497559, idle connection 144659.000000, request 304999.963522 01/08/2026 02:01:23.473 7fd8eb6395e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205477.033936, idle connection 144271.000000, request 304998.898983 01/08/2026 02:01:23.474 7fd8ebf77540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206297.900879, idle connection 144659.000000, request 304999.370098 01/08/2026 02:01:23.498 7fd8ebf772c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 139 01/08/2026 02:01:23.499 7fd8ebf772c0 [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/08/2026 02:01:23.499 7fd8ebf772c0 [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/08/2026 02:01:23.499 7fd8ebf772c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:23.499 7fd8ebf772c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=684611967, session_epoch=351, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.499 7fd8ebf772c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 354 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=684611967, session_epoch=351, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.499 7fd8ebf772c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205452.767334, idle connection 144724.000000, request 304999.948025 01/08/2026 02:01:23.500 7fd8ebf772c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205452.354248, idle connection 144723.000000, request 304999.541998 01/08/2026 02:01:23.500 7fd8e9f6f900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205091.145508, idle connection 144153.000000, request 304399.233341 01/08/2026 02:01:23.500 7fd8e9f6f900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 496 01/08/2026 02:01:23.500 7fd8e9f6f900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:23.500 7fd8e9f6f900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 496 (601.1602878570557 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=215600143, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=4127, last_stable_offset=4127, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x10\x1e\x00\x00\x00\xf8\x00\x00\x00\x00\x02\x96\xe7\x9d\x06\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\x8a\x03\x00\x00\x00\xcc\x02ObjectBgpRouter:cn-jenkins-deplo...')])]) 01/08/2026 02:01:23.501 7fd8e9f6f900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 215600143 with 1 response partitions (0 implied) 01/08/2026 02:01:23.501 7fd8e9f6f900 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 260 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 4126 01/08/2026 02:01:23.501 7fd8e9f6f900 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4126 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 01/08/2026 02:01:23.501 7fd8e9f6f900 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 4127 (leader epoch 0) 01/08/2026 02:01:23.602 7fd8e9f6f900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 4127 01/08/2026 02:01:23.602 7fd8e9f6f900 [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/08/2026 02:01:23.602 7fd8e9f6f900 [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/08/2026 02:01:23.602 7fd8e9f6f900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:23.602 7fd8e9f6f900 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=215600143, session_epoch=494, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4127, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/08/2026 02:01:23.602 7fd8e9f6f900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 497 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=215600143, session_epoch=494, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4127, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 01/08/2026 02:01:23.602 7fd8e9f6f900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204988.623535, idle connection 144050.000000, request 304999.931574 01/08/2026 02:01:23.603 7fd8e9f6f900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204988.029053, idle connection 144050.000000, request 304999.352455 01/08/2026 02:01:23.624 7fd8eb639ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 34 01/08/2026 02:01:23.624 7fd8eb639ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 01/08/2026 02:01:23.624 7fd8eb639ea0 [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)]) 01/08/2026 02:01:23.624 7fd8eb639ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:23.624 7fd8eb639ea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=235423344, session_epoch=336, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.624 7fd8eb639ea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 339 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=235423344, session_epoch=336, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.624 7fd8eb639ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205452.909912, idle connection 144384.000000, request 304999.945164 01/08/2026 02:01:23.625 7fd8eb639ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205452.458496, idle connection 144384.000000, request 304999.499321 01/08/2026 02:01:23.645 7fd8ebf770e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206180.339844, idle connection 144455.000000, request 304398.988008 01/08/2026 02:01:23.646 7fd8ebf770e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 360 01/08/2026 02:01:23.646 7fd8ebf770e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:23.646 7fd8ebf770e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 360 (601.5691757202148 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1609264503, topics=[]) 01/08/2026 02:01:23.646 7fd8ebf770e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1609264503 with 0 response partitions (1 implied) 01/08/2026 02:01:23.653 7fd8ebf77c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 140 01/08/2026 02:01:23.653 7fd8ebf77c20 [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/08/2026 02:01:23.653 7fd8ebf77c20 [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)]) 01/08/2026 02:01:23.653 7fd8ebf77c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:23.654 7fd8ebf77c20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=899604297, session_epoch=346, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.654 7fd8ebf77c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 349 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=899604297, session_epoch=346, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.654 7fd8ebf77c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206183.281738, idle connection 144561.000000, request 304999.949932 01/08/2026 02:01:23.654 7fd8ebf77c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206182.870361, idle connection 144561.000000, request 304999.543667 01/08/2026 02:01:23.665 7fd8ebf77400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205304.654541, idle connection 144477.000000, request 304399.115324 01/08/2026 02:01:23.666 7fd8ebf77400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 350 01/08/2026 02:01:23.666 7fd8ebf77400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:23.666 7fd8ebf77400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 350 (601.459264755249 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1950081189, topics=[]) 01/08/2026 02:01:23.666 7fd8ebf77400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1950081189 with 0 response partitions (1 implied) 01/08/2026 02:01:23.679 7fd8ebf777c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205181.996582, idle connection 144488.000000, request 304399.088383 01/08/2026 02:01:23.679 7fd8ebf777c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 356 01/08/2026 02:01:23.679 7fd8ebf777c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:23.679 7fd8ebf777c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 356 (601.4177799224854 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=4874832, topics=[]) 01/08/2026 02:01:23.680 7fd8ebf777c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 4874832 with 0 response partitions (1 implied) 01/08/2026 02:01:23.689 7fd8eb639860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205296.455566, idle connection 144363.000000, request 304399.053335 01/08/2026 02:01:23.690 7fd8eb639860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 367 01/08/2026 02:01:23.690 7fd8eb639860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:23.690 7fd8eb639860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 367 (601.5620231628418 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=980843328, topics=[]) 01/08/2026 02:01:23.690 7fd8eb639860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 980843328 with 0 response partitions (1 implied) 01/08/2026 02:01:23.725 7fd8ea023d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 0 01/08/2026 02:01:23.725 7fd8ea023d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 01/08/2026 02:01:23.725 7fd8ea023d60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 01/08/2026 02:01:23.725 7fd8ea023d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:23.725 7fd8ea023d60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=331045173, session_epoch=327, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.725 7fd8ea023d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 330 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=331045173, session_epoch=327, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.725 7fd8ea023d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205343.270996, idle connection 144141.000000, request 304999.943733 01/08/2026 02:01:23.726 7fd8e9f42a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 0 01/08/2026 02:01:23.726 7fd8e9f42a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 01/08/2026 02:01:23.726 7fd8e9f42a40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)]) 01/08/2026 02:01:23.726 7fd8e9f42a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:23.726 7fd8e9f42a40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=568810886, session_epoch=327, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.726 7fd8e9f42a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 330 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=568810886, session_epoch=327, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.726 7fd8e9f42a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205345.349121, idle connection 144151.000000, request 304999.951839 01/08/2026 02:01:23.727 7fd8ea023d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205341.930420, idle connection 144140.000000, request 304998.614073 01/08/2026 02:01:23.727 7fd8ea5f00e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 40 01/08/2026 02:01:23.727 7fd8ea5f00e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 01/08/2026 02:01:23.727 7fd8ea5f00e0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 01/08/2026 02:01:23.727 7fd8ea5f00e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:23.727 7fd8ea5f00e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1543064989, session_epoch=335, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.727 7fd8ea5f00e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 338 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1543064989, session_epoch=335, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.727 7fd8ea5f00e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205443.926514, idle connection 144210.000000, request 304999.957085 01/08/2026 02:01:23.728 7fd8ea023180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 4 01/08/2026 02:01:23.728 7fd8ea023180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 01/08/2026 02:01:23.728 7fd8ea023180 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 01/08/2026 02:01:23.728 7fd8ea023180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:23.728 7fd8ea023180 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1999726234, session_epoch=330, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.728 7fd8ea023180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 333 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1999726234, session_epoch=330, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.728 7fd8ea023180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205345.746826, idle connection 144107.000000, request 304999.962568 01/08/2026 02:01:23.728 7fd8e9f42a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205343.066895, idle connection 144149.000000, request 304997.673273 01/08/2026 02:01:23.729 7fd8ea5f00e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205442.468994, idle connection 144209.000000, request 304998.503685 01/08/2026 02:01:23.729 7fd8ea023180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205344.735107, idle connection 144106.000000, request 304998.954058 01/08/2026 02:01:23.772 7fd8ebf77b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 48 01/08/2026 02:01:23.772 7fd8ebf77b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 01/08/2026 02:01:23.772 7fd8ebf77b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-19', partition=0)]) 01/08/2026 02:01:23.772 7fd8ebf77b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:23.772 7fd8ebf77b80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1606196909, session_epoch=340, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.772 7fd8ebf77b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 343 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1606196909, session_epoch=340, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.773 7fd8ebf77b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205194.349609, idle connection 144497.000000, request 304999.936104 01/08/2026 02:01:23.773 7fd8ebf77b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205193.885986, idle connection 144497.000000, request 304999.483824 01/08/2026 02:01:23.773 7fd8eb639e00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205188.006592, idle connection 144302.000000, request 304399.191380 01/08/2026 02:01:23.774 7fd8eb639e00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 353 01/08/2026 02:01:23.774 7fd8eb639e00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:23.774 7fd8eb639e00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 353 (601.2668609619141 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1250139762, topics=[]) 01/08/2026 02:01:23.774 7fd8eb639e00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1250139762 with 0 response partitions (1 implied) 01/08/2026 02:01:23.797 7fd8ebf77180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 242 01/08/2026 02:01:23.797 7fd8ebf77180 [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/08/2026 02:01:23.797 7fd8ebf77180 [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/08/2026 02:01:23.797 7fd8ebf77180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:23.797 7fd8ebf77180 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1131630823, session_epoch=361, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.798 7fd8ebf77180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 364 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1131630823, session_epoch=361, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.798 7fd8ebf77180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205707.826416, idle connection 144468.000000, request 304999.924183 01/08/2026 02:01:23.798 7fd8ebf77180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205707.288330, idle connection 144468.000000, request 304999.396086 01/08/2026 02:01:23.820 7fd8eb639220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 32 01/08/2026 02:01:23.820 7fd8eb639220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 01/08/2026 02:01:23.820 7fd8eb639220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 01/08/2026 02:01:23.820 7fd8eb639220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:23.820 7fd8eb639220 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1784376784, session_epoch=336, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.820 7fd8eb639220 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 339 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1784376784, session_epoch=336, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.821 7fd8eb639220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205947.563232, idle connection 144148.000000, request 304999.937773 01/08/2026 02:01:23.821 7fd8eb639220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205947.083496, idle connection 144148.000000, request 304999.467134 01/08/2026 02:01:23.961 7fd8ebf77cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 132 01/08/2026 02:01:23.962 7fd8ebf77cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 01/08/2026 02:01:23.962 7fd8ebf77cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 01/08/2026 02:01:23.962 7fd8ebf77cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 01/08/2026 02:01:23.962 7fd8ebf77cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=517327005, session_epoch=349, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.962 7fd8ebf77cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Request 352 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=517327005, session_epoch=349, topics=[], forgotten_topics_data=[]) 01/08/2026 02:01:23.962 7fd8ebf77cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205122.475830, idle connection 144218.000000, request 304999.940872 01/08/2026 02:01:23.963 7fd8ebf77cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205121.962646, idle connection 144217.000000, request 304999.436617 01/08/2026 02:01:23.975 7fd8eb639540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205193.113525, idle connection 143731.000000, request 304397.343636 01/08/2026 02:01:23.976 7fd8eb639540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 332 01/08/2026 02:01:23.976 7fd8eb639540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:23.976 7fd8eb639540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 332 (603.1234264373779 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1086826783, topics=[]) 01/08/2026 02:01:23.976 7fd8eb639540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1086826783 with 0 response partitions (1 implied) 01/08/2026 02:01:23.976 7fd8ea26ee00 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204701.160889, idle connection 143685.000000, request 304397.279263 01/08/2026 02:01:23.976 7fd8ea26ed60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204671.322510, idle connection 143689.000000, request 304398.238659 01/08/2026 02:01:23.976 7fd8ea26ee00 [kafka.protocol.parser] [DEBUG]: Received correlation id: 330 01/08/2026 02:01:23.977 7fd8ea26ee00 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:23.977 7fd8ea26ee00 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 330 (603.2116413116455 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=480896038, topics=[]) 01/08/2026 02:01:23.977 7fd8ea26ee00 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 480896038 with 0 response partitions (1 implied) 01/08/2026 02:01:23.977 7fd8ea26ed60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 345 01/08/2026 02:01:23.977 7fd8ea26ed60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 01/08/2026 02:01:23.977 7fd8ea26ed60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.41', 9092)]>: Response 345 (602.6244163513184 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=786968917, topics=[]) 01/08/2026 02:01:23.977 7fd8ea26ed60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 786968917 with 0 response partitions (1 implied)