09/22/2025 04:27:53.270 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7926, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:53.272 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7943 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7926, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:53.272 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 222328.085205, idle connection 399516.000000, request 304999.911785 09/22/2025 04:27:53.273 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 222327.521729, idle connection 399515.000000, request 304999.362230 09/22/2025 04:27:53.394 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 217367.549316, idle connection 155875.000000, request 304398.206949 09/22/2025 04:27:53.395 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8210 09/22/2025 04:27:53.395 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:27:53.395 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 8210 (602.7665138244629 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=852287296, topics=[]) 09/22/2025 04:27:53.396 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 852287296 with 0 response partitions (1 implied) 09/22/2025 04:27:53.610 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 684 09/22/2025 04:27:53.610 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 09/22/2025 04:27:53.611 7fb4319d17c0 [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)]) 09/22/2025 04:27:53.611 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:27:53.611 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7383, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:53.611 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7402 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7383, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:53.611 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 218641.605469, idle connection 157710.000000, request 304999.935150 09/22/2025 04:27:53.612 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 218641.055664, idle connection 157709.000000, request 304999.391556 09/22/2025 04:27:53.700 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 222456.965820, idle connection 160795.000000, request 304397.443056 09/22/2025 04:27:53.701 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7669 09/22/2025 04:27:53.701 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:27:53.701 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7669 (603.4197807312012 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1462912714, topics=[]) 09/22/2025 04:27:53.701 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1462912714 with 0 response partitions (1 implied) 09/22/2025 04:27:53.728 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 218024.678223, idle connection 157148.000000, request 304397.814512 09/22/2025 04:27:53.728 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7363 09/22/2025 04:27:53.728 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:27:53.728 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7363 (602.8883457183838 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1196783146, topics=[]) 09/22/2025 04:27:53.729 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1196783146 with 0 response partitions (1 implied) 09/22/2025 04:27:53.873 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 221726.709229, idle connection 398914.000000, request 304398.538589 09/22/2025 04:27:53.874 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7943 09/22/2025 04:27:53.874 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:27:53.874 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7943 (602.1435260772705 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=427376601, topics=[]) 09/22/2025 04:27:53.874 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 427376601 with 0 response partitions (1 implied) 09/22/2025 04:27:53.997 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 7447 09/22/2025 04:27:53.998 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/22/2025 04:27:53.998 7fb43448cea0 [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)]) 09/22/2025 04:27:53.998 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:27:53.998 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8196, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:53.998 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 8211 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8196, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:53.998 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 216763.772461, idle connection 155272.000000, request 304999.938726 09/22/2025 04:27:53.999 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 216763.231445, idle connection 155271.000000, request 304999.402761 09/22/2025 04:27:54.213 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 218040.252930, idle connection 157108.000000, request 304398.574591 09/22/2025 04:27:54.213 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7402 09/22/2025 04:27:54.213 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:27:54.214 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7402 (602.4489402770996 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1827457778, topics=[]) 09/22/2025 04:27:54.214 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1827457778 with 0 response partitions (1 implied) 09/22/2025 04:27:54.302 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 2381 09/22/2025 04:27:54.303 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/22/2025 04:27:54.303 7fb431fbd040 [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)]) 09/22/2025 04:27:54.303 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:27:54.303 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7654, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:54.303 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7670 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7654, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:54.304 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 221853.745605, idle connection 160192.000000, request 304999.912739 09/22/2025 04:27:54.304 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 221853.215088, idle connection 160191.000000, request 304999.394417 09/22/2025 04:27:54.330 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 288 09/22/2025 04:27:54.330 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 09/22/2025 04:27:54.330 7fb43448cf40 [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)]) 09/22/2025 04:27:54.330 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:27:54.331 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7354, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:54.331 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7364 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7354, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:54.331 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 217421.390381, idle connection 156544.000000, request 304999.935150 09/22/2025 04:27:54.331 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 217420.888428, idle connection 156544.000000, request 304999.442577 09/22/2025 04:27:54.476 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4776 09/22/2025 04:27:54.476 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/22/2025 04:27:54.476 7fb431fdb400 [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)]) 09/22/2025 04:27:54.476 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:27:54.476 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7927, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:54.477 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7944 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7927, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:54.477 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 221123.362793, idle connection 398311.000000, request 304999.913692 09/22/2025 04:27:54.477 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 221122.745117, idle connection 398310.000000, request 304999.309063 09/22/2025 04:27:54.600 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 216162.174316, idle connection 154670.000000, request 304398.337603 09/22/2025 04:27:54.600 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8211 09/22/2025 04:27:54.600 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:27:54.601 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 8211 (602.4014949798584 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=852287296, topics=[]) 09/22/2025 04:27:54.601 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 852287296 with 0 response partitions (1 implied) 09/22/2025 04:27:54.815 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 684 09/22/2025 04:27:54.815 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 09/22/2025 04:27:54.815 7fb4319d17c0 [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)]) 09/22/2025 04:27:54.815 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:27:54.816 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7384, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:54.816 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7403 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7384, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:54.816 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 217436.912598, idle connection 156505.000000, request 304999.933720 09/22/2025 04:27:54.816 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 217436.337158, idle connection 156505.000000, request 304999.338627 09/22/2025 04:27:54.905 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 221252.015381, idle connection 159590.000000, request 304398.183346 09/22/2025 04:27:54.906 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7670 09/22/2025 04:27:54.906 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:27:54.906 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7670 (602.6067733764648 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1462912714, topics=[]) 09/22/2025 04:27:54.906 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1462912714 with 0 response partitions (1 implied) 09/22/2025 04:27:54.933 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 216819.768066, idle connection 155943.000000, request 304398.314476 09/22/2025 04:27:54.933 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7364 09/22/2025 04:27:54.933 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:27:54.933 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7364 (602.3249626159668 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1196783146, topics=[]) 09/22/2025 04:27:54.933 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1196783146 with 0 response partitions (1 implied) 09/22/2025 04:27:55.078 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 220522.013428, idle connection 397710.000000, request 304398.567915 09/22/2025 04:27:55.079 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7944 09/22/2025 04:27:55.079 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:27:55.079 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7944 (602.1633148193359 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=427376601, topics=[]) 09/22/2025 04:27:55.079 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 427376601 with 0 response partitions (1 implied) 09/22/2025 04:27:55.202 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 7447 09/22/2025 04:27:55.202 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/22/2025 04:27:55.203 7fb43448cea0 [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)]) 09/22/2025 04:27:55.203 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:27:55.203 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8197, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:55.203 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 8212 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8197, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:55.203 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 215558.665283, idle connection 154067.000000, request 304999.910355 09/22/2025 04:27:55.204 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 215557.979980, idle connection 154066.000000, request 304999.237061 09/22/2025 04:27:55.417 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 216835.664795, idle connection 155904.000000, request 304398.684502 09/22/2025 04:27:55.418 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7403 09/22/2025 04:27:55.418 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:27:55.418 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7403 (602.0863056182861 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1827457778, topics=[]) 09/22/2025 04:27:55.418 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1827457778 with 0 response partitions (1 implied) 09/22/2025 04:27:55.508 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 2381 09/22/2025 04:27:55.508 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/22/2025 04:27:55.508 7fb431fbd040 [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)]) 09/22/2025 04:27:55.508 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:27:55.508 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7655, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:55.508 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7671 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7655, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:55.509 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 220648.651123, idle connection 158987.000000, request 304999.930859 09/22/2025 04:27:55.509 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 220648.103760, idle connection 158986.000000, request 304999.394894 09/22/2025 04:27:55.534 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 288 09/22/2025 04:27:55.534 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 09/22/2025 04:27:55.534 7fb43448cf40 [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)]) 09/22/2025 04:27:55.535 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:27:55.535 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7355, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:55.535 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7365 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7355, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:55.535 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 216217.145752, idle connection 155340.000000, request 304999.922752 09/22/2025 04:27:55.536 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 216216.583252, idle connection 155340.000000, request 304999.373913 09/22/2025 04:27:55.680 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4776 09/22/2025 04:27:55.681 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/22/2025 04:27:55.681 7fb431fdb400 [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)]) 09/22/2025 04:27:55.681 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:27:55.681 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7928, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:55.681 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7945 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7928, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:55.681 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 219918.939941, idle connection 397107.000000, request 304999.938011 09/22/2025 04:27:55.682 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 219918.377197, idle connection 397106.000000, request 304999.383450 09/22/2025 04:27:55.805 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 214956.999756, idle connection 153465.000000, request 304398.245811 09/22/2025 04:27:55.806 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8212 09/22/2025 04:27:55.806 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:27:55.806 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 8212 (602.5586128234863 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=852287296, topics=[]) 09/22/2025 04:27:55.806 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 852287296 with 0 response partitions (1 implied) 09/22/2025 04:27:56.019 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 684 09/22/2025 04:27:56.019 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 09/22/2025 04:27:56.020 7fb4319d17c0 [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)]) 09/22/2025 04:27:56.020 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:27:56.020 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7385, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:56.020 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7404 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7385, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:56.020 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 216232.476807, idle connection 155301.000000, request 304999.915123 09/22/2025 04:27:56.022 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 216231.363281, idle connection 155300.000000, request 304998.813391 09/22/2025 04:27:56.111 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 220046.700439, idle connection 158385.000000, request 304397.979975 09/22/2025 04:27:56.111 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7671 09/22/2025 04:27:56.111 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:27:56.111 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7671 (602.7519702911377 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1462912714, topics=[]) 09/22/2025 04:27:56.112 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1462912714 with 0 response partitions (1 implied) 09/22/2025 04:27:56.137 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 215615.451904, idle connection 154738.000000, request 304398.235321 09/22/2025 04:27:56.137 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7365 09/22/2025 04:27:56.137 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:27:56.138 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7365 (602.5032997131348 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1196783146, topics=[]) 09/22/2025 04:27:56.138 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1196783146 with 0 response partitions (1 implied) 09/22/2025 04:27:56.283 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 219317.644287, idle connection 396505.000000, request 304398.636818 09/22/2025 04:27:56.283 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7945 09/22/2025 04:27:56.283 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:27:56.283 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7945 (602.0908355712891 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=427376601, topics=[]) 09/22/2025 04:27:56.283 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 427376601 with 0 response partitions (1 implied) 09/22/2025 04:27:56.407 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 7447 09/22/2025 04:27:56.408 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/22/2025 04:27:56.408 7fb43448cea0 [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)]) 09/22/2025 04:27:56.408 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:27:56.408 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8198, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:56.408 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 8213 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8198, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:56.409 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 214353.273193, idle connection 152861.000000, request 304999.927044 09/22/2025 04:27:56.409 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 214352.713867, idle connection 152861.000000, request 304999.378681 09/22/2025 04:27:56.622 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 215630.460449, idle connection 154699.000000, request 304397.902489 09/22/2025 04:27:56.623 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7404 09/22/2025 04:27:56.623 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:27:56.623 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7404 (602.8409004211426 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1827457778, topics=[]) 09/22/2025 04:27:56.623 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1827457778 with 0 response partitions (1 implied) 09/22/2025 04:27:56.713 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 2381 09/22/2025 04:27:56.713 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/22/2025 04:27:56.713 7fb431fbd040 [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)]) 09/22/2025 04:27:56.714 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:27:56.714 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7656, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:56.714 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7672 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7656, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:56.714 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 219443.108398, idle connection 157781.000000, request 304999.935865 09/22/2025 04:27:56.715 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 219442.451416, idle connection 157781.000000, request 304999.287128 09/22/2025 04:27:56.739 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 288 09/22/2025 04:27:56.739 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 09/22/2025 04:27:56.739 7fb43448cf40 [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)]) 09/22/2025 04:27:56.739 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:27:56.739 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7356, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:56.740 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7366 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7356, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:56.740 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 215012.477783, idle connection 154135.000000, request 304999.930859 09/22/2025 04:27:56.740 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 215011.929199, idle connection 154135.000000, request 304999.389887 09/22/2025 04:27:56.884 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4776 09/22/2025 04:27:56.885 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/22/2025 04:27:56.885 7fb431fdb400 [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)]) 09/22/2025 04:27:56.885 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:27:56.885 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7929, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:56.885 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7946 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7929, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:56.886 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 218714.620361, idle connection 395902.000000, request 304999.926329 09/22/2025 04:27:56.886 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 218714.070557, idle connection 395902.000000, request 304999.387980 09/22/2025 04:27:57.010 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 213751.794922, idle connection 152260.000000, request 304398.450851 09/22/2025 04:27:57.011 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8213 09/22/2025 04:27:57.011 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:27:57.011 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 8213 (602.4541854858398 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=852287296, topics=[]) 09/22/2025 04:27:57.011 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 852287296 with 0 response partitions (1 implied) 09/22/2025 04:27:57.225 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 684 09/22/2025 04:27:57.225 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 09/22/2025 04:27:57.225 7fb4319d17c0 [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)]) 09/22/2025 04:27:57.225 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:27:57.225 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7386, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:57.225 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7405 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7386, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:57.226 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 215027.174805, idle connection 154095.000000, request 304999.933958 09/22/2025 04:27:57.226 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 215026.665039, idle connection 154095.000000, request 304999.434233 09/22/2025 04:27:57.316 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 218841.007568, idle connection 157179.000000, request 304397.834539 09/22/2025 04:27:57.317 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7672 09/22/2025 04:27:57.317 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:27:57.317 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7672 (602.867603302002 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1462912714, topics=[]) 09/22/2025 04:27:57.317 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1462912714 with 0 response partitions (1 implied) 09/22/2025 04:27:57.342 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 214410.725342, idle connection 153534.000000, request 304398.176670 09/22/2025 04:27:57.342 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7366 09/22/2025 04:27:57.342 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:27:57.342 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7366 (602.5757789611816 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1196783146, topics=[]) 09/22/2025 04:27:57.343 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1196783146 with 0 response partitions (1 implied) 09/22/2025 04:27:57.487 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 218113.295166, idle connection 395301.000000, request 304398.601532 09/22/2025 04:27:57.487 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7946 09/22/2025 04:27:57.488 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:27:57.488 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7946 (602.1261215209961 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=427376601, topics=[]) 09/22/2025 04:27:57.488 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 427376601 with 0 response partitions (1 implied) 09/22/2025 04:27:57.613 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 7447 09/22/2025 04:27:57.613 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/22/2025 04:27:57.613 7fb43448cea0 [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)]) 09/22/2025 04:27:57.613 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:27:57.613 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8199, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:57.614 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 8214 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8199, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:57.614 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 213148.214355, idle connection 151656.000000, request 304999.917507 09/22/2025 04:27:57.614 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 213147.633545, idle connection 151656.000000, request 304999.354124 09/22/2025 04:27:57.827 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 214426.013184, idle connection 153494.000000, request 304398.768902 09/22/2025 04:27:57.827 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7405 09/22/2025 04:27:57.827 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:27:57.828 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7405 (601.9618511199951 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1827457778, topics=[]) 09/22/2025 04:27:57.828 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1827457778 with 0 response partitions (1 implied) 09/22/2025 04:27:57.919 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 2381 09/22/2025 04:27:57.919 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/22/2025 04:27:57.919 7fb431fbd040 [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)]) 09/22/2025 04:27:57.919 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:27:57.919 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7657, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:57.919 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7673 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7657, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:57.920 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 218237.629639, idle connection 156576.000000, request 304999.933481 09/22/2025 04:27:57.920 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 218237.072998, idle connection 156575.000000, request 304999.387980 09/22/2025 04:27:57.944 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 288 09/22/2025 04:27:57.944 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 09/22/2025 04:27:57.944 7fb43448cf40 [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)]) 09/22/2025 04:27:57.945 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:27:57.945 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7357, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:57.945 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7367 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7357, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:57.945 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 213807.300049, idle connection 152930.000000, request 304999.935389 09/22/2025 04:27:57.946 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 213806.759766, idle connection 152930.000000, request 304999.403954 09/22/2025 04:27:58.089 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4776 09/22/2025 04:27:58.089 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/22/2025 04:27:58.089 7fb431fdb400 [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)]) 09/22/2025 04:27:58.089 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:27:58.089 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7930, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:58.090 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7947 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7930, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:58.091 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 217509.630859, idle connection 394697.000000, request 304999.368668 09/22/2025 04:27:58.091 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 217509.022949, idle connection 394697.000000, request 304998.775959 09/22/2025 04:27:58.215 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 212546.679199, idle connection 151055.000000, request 304398.390532 09/22/2025 04:27:58.216 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8214 09/22/2025 04:27:58.216 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:27:58.216 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 8214 (602.323055267334 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=852287296, topics=[]) 09/22/2025 04:27:58.216 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 852287296 with 0 response partitions (1 implied) 09/22/2025 04:27:58.429 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 684 09/22/2025 04:27:58.429 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 09/22/2025 04:27:58.429 7fb4319d17c0 [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)]) 09/22/2025 04:27:58.429 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:27:58.430 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7387, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:58.430 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7406 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7387, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:58.430 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 213822.816895, idle connection 152891.000000, request 304999.931812 09/22/2025 04:27:58.430 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 213822.280762, idle connection 152890.000000, request 304999.408484 09/22/2025 04:27:58.521 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 217635.921875, idle connection 155974.000000, request 304398.224592 09/22/2025 04:27:58.522 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7673 09/22/2025 04:27:58.522 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:27:58.522 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7673 (602.4982929229736 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1462912714, topics=[]) 09/22/2025 04:27:58.522 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1462912714 with 0 response partitions (1 implied) 09/22/2025 04:27:58.547 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 213205.667969, idle connection 152329.000000, request 304398.303270 09/22/2025 04:27:58.547 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7367 09/22/2025 04:27:58.547 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:27:58.547 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7367 (602.3523807525635 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1196783146, topics=[]) 09/22/2025 04:27:58.547 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1196783146 with 0 response partitions (1 implied) 09/22/2025 04:27:58.693 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 216907.319336, idle connection 394095.000000, request 304397.058249 09/22/2025 04:27:58.693 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7947 09/22/2025 04:27:58.693 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:27:58.694 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7947 (603.6515235900879 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=427376601, topics=[]) 09/22/2025 04:27:58.694 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 427376601 with 0 response partitions (1 implied) 09/22/2025 04:27:58.818 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 7447 09/22/2025 04:27:58.818 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/22/2025 04:27:58.818 7fb43448cea0 [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)]) 09/22/2025 04:27:58.818 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:27:58.818 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8200, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:58.818 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 8215 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8200, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:58.819 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 211943.431885, idle connection 150451.000000, request 304999.921799 09/22/2025 04:27:58.819 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 211942.895020, idle connection 150451.000000, request 304999.395370 09/22/2025 04:27:59.032 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 213221.156494, idle connection 152289.000000, request 304398.272514 09/22/2025 04:27:59.032 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7406 09/22/2025 04:27:59.032 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:27:59.032 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7406 (602.4439334869385 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1827457778, topics=[]) 09/22/2025 04:27:59.033 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1827457778 with 0 response partitions (1 implied) 09/22/2025 04:27:59.123 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 2381 09/22/2025 04:27:59.123 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/22/2025 04:27:59.123 7fb431fbd040 [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)]) 09/22/2025 04:27:59.123 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:27:59.123 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7658, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:59.124 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7674 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7658, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:59.124 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 217033.493408, idle connection 155372.000000, request 304999.936342 09/22/2025 04:27:59.124 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 217032.979004, idle connection 155371.000000, request 304999.430656 09/22/2025 04:27:59.148 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 288 09/22/2025 04:27:59.148 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 09/22/2025 04:27:59.148 7fb43448cf40 [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)]) 09/22/2025 04:27:59.148 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:27:59.148 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7358, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:59.148 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7368 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7358, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:59.149 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 212603.703369, idle connection 151727.000000, request 304999.948025 09/22/2025 04:27:59.149 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 212603.318604, idle connection 151726.000000, request 304999.566078 09/22/2025 04:27:59.294 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4776 09/22/2025 04:27:59.295 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/22/2025 04:27:59.295 7fb431fdb400 [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)]) 09/22/2025 04:27:59.295 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:27:59.295 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7931, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:59.295 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7948 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7931, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:59.295 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 216304.764893, idle connection 393492.000000, request 304999.935389 09/22/2025 04:27:59.296 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 216304.244629, idle connection 393492.000000, request 304999.425173 09/22/2025 04:27:59.420 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 211342.256104, idle connection 149850.000000, request 304398.745298 09/22/2025 04:27:59.420 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8215 09/22/2025 04:27:59.420 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:27:59.420 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 8215 (601.905345916748 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=852287296, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=7449, last_stable_offset=7449, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x1d\x17\x00\x00\x01\xfb\x00\x00\x00\x00\x02\x1e\x95\x9bX\x00\x00\x00\x00\x00\x01\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x02\xc6\x03\x00\x00\x00\x88\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 09/22/2025 04:27:59.421 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 852287296 with 1 response partitions (0 implied) 09/22/2025 04:27:59.421 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 519 bytes of data for partition TopicPartition(topic='-uve-topic-28', partition=0) with offset 7447 09/22/2025 04:27:59.421 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 7447 for assigned partition TopicPartition(topic='-uve-topic-28', partition=0) 09/22/2025 04:27:59.421 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-28', partition=0) to 7449 (leader epoch 0) 09/22/2025 04:27:59.522 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 7449 09/22/2025 04:27:59.522 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/22/2025 04:27:59.522 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-28', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 09/22/2025 04:27:59.523 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:27:59.523 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8201, topics=[(topic='-uve-topic-28', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=7449, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/22/2025 04:27:59.523 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 8216 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8201, topics=[(topic='-uve-topic-28', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=7449, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/22/2025 04:27:59.523 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 211238.872070, idle connection 149747.000000, request 304999.928951 09/22/2025 04:27:59.524 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 211238.356445, idle connection 149746.000000, request 304999.422789 09/22/2025 04:27:59.633 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 684 09/22/2025 04:27:59.633 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 09/22/2025 04:27:59.633 7fb4319d17c0 [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)]) 09/22/2025 04:27:59.634 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:27:59.634 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7388, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:59.634 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7407 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7388, topics=[], forgotten_topics_data=[]) 09/22/2025 04:27:59.634 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 212618.821777, idle connection 151687.000000, request 304999.935150 09/22/2025 04:27:59.634 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 212618.335693, idle connection 151687.000000, request 304999.459505 09/22/2025 04:27:59.725 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 216432.287354, idle connection 154770.000000, request 304398.728609 09/22/2025 04:27:59.725 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7674 09/22/2025 04:27:59.726 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:27:59.726 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7674 (601.9513607025146 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1462912714, topics=[]) 09/22/2025 04:27:59.726 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1462912714 with 0 response partitions (1 implied) 09/22/2025 04:27:59.750 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 212002.776367, idle connection 151126.000000, request 304399.010658 09/22/2025 04:27:59.750 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7368 09/22/2025 04:27:59.750 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:27:59.750 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7368 (601.76682472229 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1196783146, topics=[]) 09/22/2025 04:27:59.751 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1196783146 with 0 response partitions (1 implied) 09/22/2025 04:27:59.897 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 215703.551025, idle connection 392891.000000, request 304398.717880 09/22/2025 04:27:59.897 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7948 09/22/2025 04:27:59.897 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:27:59.897 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7948 (602.006196975708 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=427376601, topics=[]) 09/22/2025 04:27:59.898 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 427376601 with 0 response partitions (1 implied) 09/22/2025 04:28:00.124 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210637.539307, idle connection 149145.000000, request 304398.595095 09/22/2025 04:28:00.125 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8216 09/22/2025 04:28:00.125 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:00.125 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 8216 (602.1296977996826 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=852287296, topics=[]) 09/22/2025 04:28:00.125 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 852287296 with 0 response partitions (1 implied) 09/22/2025 04:28:00.235 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 212017.703369, idle connection 151086.000000, request 304398.816586 09/22/2025 04:28:00.236 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7407 09/22/2025 04:28:00.236 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:00.236 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7407 (601.935863494873 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1827457778, topics=[]) 09/22/2025 04:28:00.236 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1827457778 with 0 response partitions (1 implied) 09/22/2025 04:28:00.328 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 2381 09/22/2025 04:28:00.328 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/22/2025 04:28:00.328 7fb431fbd040 [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)]) 09/22/2025 04:28:00.328 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:00.328 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7659, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:00.328 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7675 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7659, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:00.329 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 215828.709229, idle connection 154167.000000, request 304999.915361 09/22/2025 04:28:00.329 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 215828.042480, idle connection 154166.000000, request 304999.259472 09/22/2025 04:28:00.352 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 288 09/22/2025 04:28:00.352 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 09/22/2025 04:28:00.353 7fb43448cf40 [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)]) 09/22/2025 04:28:00.353 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:00.353 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7359, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:00.353 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7369 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7359, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:00.353 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 211399.013672, idle connection 150522.000000, request 304999.928474 09/22/2025 04:28:00.354 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 211398.443115, idle connection 150521.000000, request 304999.369144 09/22/2025 04:28:00.499 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4776 09/22/2025 04:28:00.500 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/22/2025 04:28:00.500 7fb431fdb400 [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)]) 09/22/2025 04:28:00.500 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:00.500 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7932, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:00.500 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7949 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7932, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:00.500 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 215100.037109, idle connection 392288.000000, request 304999.932766 09/22/2025 04:28:00.501 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 215099.465576, idle connection 392287.000000, request 304999.372482 09/22/2025 04:28:00.727 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 7449 09/22/2025 04:28:00.727 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/22/2025 04:28:00.727 7fb43448cea0 [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)]) 09/22/2025 04:28:00.727 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:00.727 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8202, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:00.728 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 8217 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8202, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:00.728 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210034.162842, idle connection 148542.000000, request 304999.927998 09/22/2025 04:28:00.728 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210033.636230, idle connection 148542.000000, request 304999.413729 09/22/2025 04:28:00.837 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 684 09/22/2025 04:28:00.837 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 09/22/2025 04:28:00.838 7fb4319d17c0 [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)]) 09/22/2025 04:28:00.838 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:00.838 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7389, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:00.838 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7408 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7389, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:00.838 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 211414.695801, idle connection 150483.000000, request 304999.934196 09/22/2025 04:28:00.839 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 211414.173340, idle connection 150482.000000, request 304999.423027 09/22/2025 04:28:00.931 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 215226.448975, idle connection 153565.000000, request 304397.657394 09/22/2025 04:28:00.931 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7675 09/22/2025 04:28:00.931 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:00.932 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7675 (603.0805110931396 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1462912714, topics=[]) 09/22/2025 04:28:00.932 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1462912714 with 0 response partitions (1 implied) 09/22/2025 04:28:00.955 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210797.160400, idle connection 149920.000000, request 304398.068190 09/22/2025 04:28:00.956 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7369 09/22/2025 04:28:00.956 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:00.956 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7369 (602.820634841919 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1196783146, topics=[]) 09/22/2025 04:28:00.956 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1196783146 with 0 response partitions (1 implied) 09/22/2025 04:28:01.102 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 214498.541016, idle connection 391686.000000, request 304398.436069 09/22/2025 04:28:01.102 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7949 09/22/2025 04:28:01.102 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:01.102 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7949 (602.276086807251 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=427376601, topics=[]) 09/22/2025 04:28:01.103 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 427376601 with 0 response partitions (1 implied) 09/22/2025 04:28:01.329 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209432.713135, idle connection 147941.000000, request 304398.476839 09/22/2025 04:28:01.330 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8217 09/22/2025 04:28:01.330 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:01.330 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 8217 (602.3857593536377 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=852287296, topics=[]) 09/22/2025 04:28:01.330 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 852287296 with 0 response partitions (1 implied) 09/22/2025 04:28:01.439 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210813.488770, idle connection 149882.000000, request 304398.725033 09/22/2025 04:28:01.440 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7408 09/22/2025 04:28:01.440 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:01.440 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7408 (602.0033359527588 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1827457778, topics=[]) 09/22/2025 04:28:01.440 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1827457778 with 0 response partitions (1 implied) 09/22/2025 04:28:01.533 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 2381 09/22/2025 04:28:01.533 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/22/2025 04:28:01.533 7fb431fbd040 [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)]) 09/22/2025 04:28:01.533 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:01.533 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7660, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:01.534 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7676 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7660, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:01.534 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 214623.501465, idle connection 152962.000000, request 304999.932051 09/22/2025 04:28:01.534 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 214622.969971, idle connection 152961.000000, request 304999.411821 09/22/2025 04:28:01.557 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 288 09/22/2025 04:28:01.558 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 09/22/2025 04:28:01.558 7fb43448cf40 [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)]) 09/22/2025 04:28:01.558 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:01.558 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7360, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:01.558 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7370 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7360, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:01.558 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210193.955566, idle connection 149317.000000, request 304999.936581 09/22/2025 04:28:01.559 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210193.391357, idle connection 149316.000000, request 304999.380827 09/22/2025 04:28:01.704 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4776 09/22/2025 04:28:01.704 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/22/2025 04:28:01.704 7fb431fdb400 [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)]) 09/22/2025 04:28:01.704 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:01.704 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7933, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:01.705 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7950 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7933, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:01.705 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 213895.401367, idle connection 391083.000000, request 304999.926805 09/22/2025 04:28:01.705 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 213894.816650, idle connection 391082.000000, request 304999.353409 09/22/2025 04:28:01.932 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 7449 09/22/2025 04:28:01.932 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/22/2025 04:28:01.932 7fb43448cea0 [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)]) 09/22/2025 04:28:01.932 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:01.932 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8203, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:01.933 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 8218 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8203, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:01.933 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208829.112061, idle connection 147337.000000, request 304999.930382 09/22/2025 04:28:01.933 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208828.618408, idle connection 147337.000000, request 304999.450445 09/22/2025 04:28:02.041 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 684 09/22/2025 04:28:02.042 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 09/22/2025 04:28:02.042 7fb4319d17c0 [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)]) 09/22/2025 04:28:02.042 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:02.042 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7390, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:02.042 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7409 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7390, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:02.042 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210210.574219, idle connection 149279.000000, request 304999.929667 09/22/2025 04:28:02.043 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210209.975586, idle connection 149278.000000, request 304999.342203 09/22/2025 04:28:02.136 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 214021.475342, idle connection 152360.000000, request 304397.898674 09/22/2025 04:28:02.136 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7676 09/22/2025 04:28:02.137 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:02.137 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7676 (603.0395030975342 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1462912714, topics=[]) 09/22/2025 04:28:02.137 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1462912714 with 0 response partitions (1 implied) 09/22/2025 04:28:02.160 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209591.831055, idle connection 148715.000000, request 304397.799969 09/22/2025 04:28:02.161 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7370 09/22/2025 04:28:02.161 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:02.161 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7370 (602.9341220855713 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1196783146, topics=[]) 09/22/2025 04:28:02.161 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1196783146 with 0 response partitions (1 implied) 09/22/2025 04:28:02.306 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 213293.904541, idle connection 390482.000000, request 304398.427725 09/22/2025 04:28:02.307 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7950 09/22/2025 04:28:02.307 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:02.307 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7950 (602.4088859558105 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=427376601, topics=[]) 09/22/2025 04:28:02.307 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 427376601 with 0 response partitions (1 implied) 09/22/2025 04:28:02.535 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208227.464600, idle connection 146735.000000, request 304398.284435 09/22/2025 04:28:02.535 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8218 09/22/2025 04:28:02.535 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:02.535 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 8218 (602.4622917175293 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=852287296, topics=[]) 09/22/2025 04:28:02.535 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 852287296 with 0 response partitions (1 implied) 09/22/2025 04:28:02.644 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209609.154297, idle connection 148677.000000, request 304398.508787 09/22/2025 04:28:02.644 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7409 09/22/2025 04:28:02.644 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:02.644 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7409 (602.2186279296875 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1827457778, topics=[]) 09/22/2025 04:28:02.645 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1827457778 with 0 response partitions (1 implied) 09/22/2025 04:28:02.738 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 2381 09/22/2025 04:28:02.738 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/22/2025 04:28:02.739 7fb431fbd040 [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)]) 09/22/2025 04:28:02.739 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:02.739 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7661, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:02.739 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7677 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7661, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:02.739 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 213417.916748, idle connection 151756.000000, request 304999.913454 09/22/2025 04:28:02.740 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 213417.333008, idle connection 151755.000000, request 304999.348640 09/22/2025 04:28:02.763 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 288 09/22/2025 04:28:02.763 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 09/22/2025 04:28:02.763 7fb43448cf40 [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)]) 09/22/2025 04:28:02.763 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:02.763 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7361, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:02.764 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7371 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7361, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:02.764 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208988.441650, idle connection 148111.000000, request 304999.934196 09/22/2025 04:28:02.764 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208987.892334, idle connection 148111.000000, request 304999.393940 09/22/2025 04:28:02.909 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4776 09/22/2025 04:28:02.910 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/22/2025 04:28:02.910 7fb431fdb400 [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)]) 09/22/2025 04:28:02.910 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:02.910 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7934, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:02.910 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7951 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7934, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:02.910 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 212689.880127, idle connection 389878.000000, request 304999.927759 09/22/2025 04:28:02.911 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 212689.344482, idle connection 389877.000000, request 304999.404430 09/22/2025 04:28:03.137 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 7449 09/22/2025 04:28:03.137 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/22/2025 04:28:03.137 7fb43448cea0 [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)]) 09/22/2025 04:28:03.137 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:03.138 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8204, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:03.138 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 8219 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8204, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:03.138 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207623.860596, idle connection 146132.000000, request 304999.914885 09/22/2025 04:28:03.139 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207623.102051, idle connection 146131.000000, request 304999.168634 09/22/2025 04:28:03.246 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 684 09/22/2025 04:28:03.246 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 09/22/2025 04:28:03.246 7fb4319d17c0 [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)]) 09/22/2025 04:28:03.246 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:03.246 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7391, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:03.247 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7410 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7391, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:03.247 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209005.963623, idle connection 148074.000000, request 304999.887943 09/22/2025 04:28:03.247 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209005.351562, idle connection 148074.000000, request 304999.293327 09/22/2025 04:28:03.341 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 212815.985840, idle connection 151154.000000, request 304397.990465 09/22/2025 04:28:03.342 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7677 09/22/2025 04:28:03.342 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:03.342 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7677 (602.8397083282471 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1462912714, topics=[]) 09/22/2025 04:28:03.342 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1462912714 with 0 response partitions (1 implied) 09/22/2025 04:28:03.366 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208386.065430, idle connection 147509.000000, request 304397.555828 09/22/2025 04:28:03.367 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7371 09/22/2025 04:28:03.367 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:03.367 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7371 (603.1718254089355 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1196783146, topics=[]) 09/22/2025 04:28:03.367 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1196783146 with 0 response partitions (1 implied) 09/22/2025 04:28:03.512 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 212088.464844, idle connection 389276.000000, request 304398.509264 09/22/2025 04:28:03.512 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7951 09/22/2025 04:28:03.512 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:03.512 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7951 (602.2276878356934 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=427376601, topics=[]) 09/22/2025 04:28:03.513 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 427376601 with 0 response partitions (1 implied) 09/22/2025 04:28:03.740 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207022.106445, idle connection 145530.000000, request 304398.165464 09/22/2025 04:28:03.740 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8219 09/22/2025 04:28:03.740 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:03.741 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 8219 (602.5667190551758 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=852287296, topics=[]) 09/22/2025 04:28:03.741 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 852287296 with 0 response partitions (1 implied) 09/22/2025 04:28:03.848 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208404.648438, idle connection 147473.000000, request 304398.578644 09/22/2025 04:28:03.849 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7410 09/22/2025 04:28:03.849 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:03.849 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7410 (602.1196842193604 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1827457778, topics=[]) 09/22/2025 04:28:03.849 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1827457778 with 0 response partitions (1 implied) 09/22/2025 04:28:03.944 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 2381 09/22/2025 04:28:03.944 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/22/2025 04:28:03.944 7fb431fbd040 [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)]) 09/22/2025 04:28:03.944 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:03.944 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7662, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:03.944 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7678 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7662, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:03.945 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 212212.676270, idle connection 150551.000000, request 304999.936581 09/22/2025 04:28:03.945 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 212212.155029, idle connection 150550.000000, request 304999.425888 09/22/2025 04:28:03.968 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 288 09/22/2025 04:28:03.968 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 09/22/2025 04:28:03.968 7fb43448cf40 [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)]) 09/22/2025 04:28:03.968 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:03.969 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7362, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:03.969 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7372 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7362, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:03.969 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207783.394775, idle connection 146906.000000, request 304999.937534 09/22/2025 04:28:03.969 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207782.885010, idle connection 146906.000000, request 304999.437094 09/22/2025 04:28:04.115 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4776 09/22/2025 04:28:04.115 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/22/2025 04:28:04.115 7fb431fdb400 [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)]) 09/22/2025 04:28:04.116 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:04.116 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7935, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:04.116 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7952 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7935, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:04.116 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 211483.962158, idle connection 388672.000000, request 304999.906063 09/22/2025 04:28:04.117 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 211483.230957, idle connection 388671.000000, request 304999.187469 09/22/2025 04:28:04.342 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 7449 09/22/2025 04:28:04.342 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/22/2025 04:28:04.343 7fb43448cea0 [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)]) 09/22/2025 04:28:04.343 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:04.343 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8205, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:04.343 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 8220 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8205, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:04.343 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206418.808838, idle connection 144927.000000, request 304999.931574 09/22/2025 04:28:04.344 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206418.216064, idle connection 144926.000000, request 304999.350071 09/22/2025 04:28:04.450 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 684 09/22/2025 04:28:04.450 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 09/22/2025 04:28:04.450 7fb4319d17c0 [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)]) 09/22/2025 04:28:04.450 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:04.450 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7392, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:04.451 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7411 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7392, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:04.451 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207802.072266, idle connection 146870.000000, request 304999.924898 09/22/2025 04:28:04.451 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207801.552979, idle connection 146870.000000, request 304999.416828 09/22/2025 04:28:04.546 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 211610.916748, idle connection 149949.000000, request 304398.176432 09/22/2025 04:28:04.547 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7678 09/22/2025 04:28:04.547 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:04.547 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7678 (602.6308536529541 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1462912714, topics=[]) 09/22/2025 04:28:04.547 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1462912714 with 0 response partitions (1 implied) 09/22/2025 04:28:04.571 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207181.579590, idle connection 146305.000000, request 304398.119211 09/22/2025 04:28:04.571 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7372 09/22/2025 04:28:04.571 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:04.571 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7372 (602.5643348693848 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1196783146, topics=[]) 09/22/2025 04:28:04.572 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1196783146 with 0 response partitions (1 implied) 09/22/2025 04:28:04.718 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210882.179932, idle connection 388070.000000, request 304398.021698 09/22/2025 04:28:04.719 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7952 09/22/2025 04:28:04.719 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:04.719 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7952 (602.8149127960205 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=427376601, topics=[]) 09/22/2025 04:28:04.719 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 427376601 with 0 response partitions (1 implied) 09/22/2025 04:28:04.944 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205817.502930, idle connection 144325.000000, request 304398.619413 09/22/2025 04:28:04.945 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8220 09/22/2025 04:28:04.945 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:04.945 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 8220 (602.1125316619873 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=852287296, topics=[(topics='-uve-topic-28', partitions=[(partition=0, error_code=0, highwater_offset=7451, last_stable_offset=7451, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x1d\x19\x00\x00\x02\x17\x00\x00\x00\x00\x02A\x87\xael\x00\x00\x00\x00\x00\x01\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x02\xe2\x03\x00\x00\x00\xa4\x03ObjectGeneratorInfo:cn-jenkins-d...')])]) 09/22/2025 04:28:04.945 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 852287296 with 1 response partitions (0 implied) 09/22/2025 04:28:04.946 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 547 bytes of data for partition TopicPartition(topic='-uve-topic-28', partition=0) with offset 7449 09/22/2025 04:28:04.946 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 7449 for assigned partition TopicPartition(topic='-uve-topic-28', partition=0) 09/22/2025 04:28:04.946 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-28', partition=0) to 7451 (leader epoch 0) 09/22/2025 04:28:05.047 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 7451 09/22/2025 04:28:05.047 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/22/2025 04:28:05.047 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-28', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-28', partition=0)]) 09/22/2025 04:28:05.047 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:05.047 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8206, topics=[(topic='-uve-topic-28', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=7451, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/22/2025 04:28:05.048 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 8221 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8206, topics=[(topic='-uve-topic-28', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=7451, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 09/22/2025 04:28:05.048 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205714.064209, idle connection 144222.000000, request 304999.934673 09/22/2025 04:28:05.048 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205713.495361, idle connection 144221.000000, request 304999.367952 09/22/2025 04:28:05.052 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207200.999023, idle connection 146269.000000, request 304398.859024 09/22/2025 04:28:05.052 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7411 09/22/2025 04:28:05.052 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:05.052 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7411 (601.6845703125 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1827457778, topics=[]) 09/22/2025 04:28:05.053 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1827457778 with 0 response partitions (1 implied) 09/22/2025 04:28:05.148 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 2381 09/22/2025 04:28:05.148 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/22/2025 04:28:05.149 7fb431fbd040 [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)]) 09/22/2025 04:28:05.149 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:05.149 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7663, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:05.149 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7679 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7663, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:05.149 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 211008.197021, idle connection 149346.000000, request 304999.933958 09/22/2025 04:28:05.150 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 211007.538330, idle connection 149346.000000, request 304999.284744 09/22/2025 04:28:05.173 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 288 09/22/2025 04:28:05.173 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 09/22/2025 04:28:05.173 7fb43448cf40 [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)]) 09/22/2025 04:28:05.173 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:05.173 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7363, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:05.174 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7373 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7363, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:05.174 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206578.301270, idle connection 145701.000000, request 304999.933004 09/22/2025 04:28:05.174 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206577.831299, idle connection 145701.000000, request 304999.473810 09/22/2025 04:28:05.321 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4776 09/22/2025 04:28:05.321 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/22/2025 04:28:05.321 7fb431fdb400 [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)]) 09/22/2025 04:28:05.321 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:05.321 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7936, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:05.321 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7953 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7936, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:05.322 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210278.450928, idle connection 387466.000000, request 304999.913454 09/22/2025 04:28:05.322 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210277.905762, idle connection 387466.000000, request 304999.382496 09/22/2025 04:28:05.650 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205112.299805, idle connection 143620.000000, request 304398.169041 09/22/2025 04:28:05.650 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8221 09/22/2025 04:28:05.650 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:05.650 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 8221 (602.5505065917969 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=852287296, topics=[]) 09/22/2025 04:28:05.651 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 852287296 with 0 response partitions (1 implied) 09/22/2025 04:28:05.653 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 684 09/22/2025 04:28:05.653 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 09/22/2025 04:28:05.654 7fb4319d17c0 [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)]) 09/22/2025 04:28:05.654 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:05.654 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7393, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:05.654 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7412 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7393, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:05.654 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206598.757324, idle connection 145667.000000, request 304999.945641 09/22/2025 04:28:05.654 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206598.285645, idle connection 145666.000000, request 304999.480724 09/22/2025 04:28:05.751 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 210406.092285, idle connection 148744.000000, request 304397.827148 09/22/2025 04:28:05.752 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7679 09/22/2025 04:28:05.752 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:05.752 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7679 (602.8690338134766 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1462912714, topics=[]) 09/22/2025 04:28:05.752 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1462912714 with 0 response partitions (1 implied) 09/22/2025 04:28:05.775 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205976.804443, idle connection 145100.000000, request 304398.436308 09/22/2025 04:28:05.776 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7373 09/22/2025 04:28:05.776 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:05.776 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7373 (602.1881103515625 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1196783146, topics=[]) 09/22/2025 04:28:05.776 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1196783146 with 0 response partitions (1 implied) 09/22/2025 04:28:05.923 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209676.756836, idle connection 386864.000000, request 304398.221493 09/22/2025 04:28:05.924 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7953 09/22/2025 04:28:05.924 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:05.924 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7953 (602.51784324646 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=427376601, topics=[]) 09/22/2025 04:28:05.924 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 427376601 with 0 response partitions (1 implied) 09/22/2025 04:28:06.251 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 7451 09/22/2025 04:28:06.251 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/22/2025 04:28:06.252 7fb43448cea0 [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)]) 09/22/2025 04:28:06.252 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:06.252 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8207, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:06.252 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 8222 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8207, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:06.252 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204509.577637, idle connection 143018.000000, request 304999.916077 09/22/2025 04:28:06.253 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204508.583984, idle connection 143017.000000, request 304998.932600 09/22/2025 04:28:06.255 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205997.695801, idle connection 145066.000000, request 304398.886919 09/22/2025 04:28:06.255 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7412 09/22/2025 04:28:06.255 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:06.256 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7412 (601.6004085540771 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1827457778, topics=[]) 09/22/2025 04:28:06.256 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1827457778 with 0 response partitions (1 implied) 09/22/2025 04:28:06.353 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 2381 09/22/2025 04:28:06.354 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/22/2025 04:28:06.354 7fb431fbd040 [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)]) 09/22/2025 04:28:06.354 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:06.354 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7664, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:06.354 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7680 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7664, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:06.355 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209802.726562, idle connection 148141.000000, request 304999.931812 09/22/2025 04:28:06.355 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209802.017334, idle connection 148140.000000, request 304999.233961 09/22/2025 04:28:06.377 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 288 09/22/2025 04:28:06.377 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 09/22/2025 04:28:06.378 7fb43448cf40 [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)]) 09/22/2025 04:28:06.378 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:06.378 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7364, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:06.378 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7374 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7364, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:06.378 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205373.902588, idle connection 144497.000000, request 304999.907494 09/22/2025 04:28:06.379 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205373.046875, idle connection 144496.000000, request 304999.068260 09/22/2025 04:28:06.526 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4776 09/22/2025 04:28:06.526 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/22/2025 04:28:06.526 7fb431fdb400 [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)]) 09/22/2025 04:28:06.526 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:06.526 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7937, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:06.526 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7954 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7937, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:06.527 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209073.596436, idle connection 386261.000000, request 304999.933720 09/22/2025 04:28:06.527 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209073.000488, idle connection 386261.000000, request 304999.342680 09/22/2025 04:28:06.855 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203906.780518, idle connection 142415.000000, request 304397.110462 09/22/2025 04:28:06.856 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8222 09/22/2025 04:28:06.856 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:06.856 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 8222 (603.7595272064209 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=852287296, topics=[]) 09/22/2025 04:28:06.856 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 852287296 with 0 response partitions (1 implied) 09/22/2025 04:28:06.857 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 684 09/22/2025 04:28:06.857 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 09/22/2025 04:28:06.857 7fb4319d17c0 [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)]) 09/22/2025 04:28:06.857 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:06.857 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7394, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:06.857 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7413 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7394, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:06.858 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205395.173096, idle connection 144463.000000, request 304999.944210 09/22/2025 04:28:06.859 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205393.914307, idle connection 144462.000000, request 304998.686552 09/22/2025 04:28:06.956 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 209201.013428, idle connection 147539.000000, request 304398.211956 09/22/2025 04:28:06.957 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7680 09/22/2025 04:28:06.957 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:06.957 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7680 (602.5934219360352 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1462912714, topics=[]) 09/22/2025 04:28:06.957 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1462912714 with 0 response partitions (1 implied) 09/22/2025 04:28:06.981 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204771.778564, idle connection 143895.000000, request 304397.790909 09/22/2025 04:28:06.981 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7374 09/22/2025 04:28:06.981 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:06.981 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7374 (602.8177738189697 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1196783146, topics=[]) 09/22/2025 04:28:06.981 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1196783146 with 0 response partitions (1 implied) 09/22/2025 04:28:07.129 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208471.461426, idle connection 385659.000000, request 304397.794247 09/22/2025 04:28:07.129 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7954 09/22/2025 04:28:07.129 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:07.130 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7954 (603.0149459838867 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=427376601, topics=[]) 09/22/2025 04:28:07.130 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 427376601 with 0 response partitions (1 implied) 09/22/2025 04:28:07.458 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 7451 09/22/2025 04:28:07.458 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/22/2025 04:28:07.458 7fb43448cea0 [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)]) 09/22/2025 04:28:07.458 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:07.458 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8208, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:07.459 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 8223 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8208, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:07.459 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203302.975586, idle connection 141811.000000, request 304999.927521 09/22/2025 04:28:07.460 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203302.432129, idle connection 141810.000000, request 304999.391556 09/22/2025 04:28:07.460 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204792.353027, idle connection 143861.000000, request 304397.128105 09/22/2025 04:28:07.461 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7413 09/22/2025 04:28:07.461 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:07.461 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7413 (603.4095287322998 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1827457778, topics=[]) 09/22/2025 04:28:07.461 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1827457778 with 0 response partitions (1 implied) 09/22/2025 04:28:07.559 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 2381 09/22/2025 04:28:07.559 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/22/2025 04:28:07.559 7fb431fbd040 [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)]) 09/22/2025 04:28:07.559 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:07.559 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7665, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:07.559 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7681 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7665, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:07.560 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208597.587646, idle connection 146936.000000, request 304999.929190 09/22/2025 04:28:07.560 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 208596.840576, idle connection 146935.000000, request 304999.193192 09/22/2025 04:28:07.582 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 288 09/22/2025 04:28:07.583 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 09/22/2025 04:28:07.583 7fb43448cf40 [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)]) 09/22/2025 04:28:07.583 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:07.583 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7365, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:07.583 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7375 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7365, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:07.583 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204168.937744, idle connection 143292.000000, request 304999.928236 09/22/2025 04:28:07.584 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204168.360840, idle connection 143291.000000, request 304999.361992 09/22/2025 04:28:07.731 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4776 09/22/2025 04:28:07.731 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/22/2025 04:28:07.732 7fb431fdb400 [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)]) 09/22/2025 04:28:07.732 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:07.732 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7938, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:07.732 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7955 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7938, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:07.732 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207868.126465, idle connection 385056.000000, request 304999.931574 09/22/2025 04:28:07.733 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207867.590088, idle connection 385055.000000, request 304999.406338 09/22/2025 04:28:08.060 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 202701.587646, idle connection 141210.000000, request 304398.531437 09/22/2025 04:28:08.061 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8223 09/22/2025 04:28:08.061 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:08.062 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 8223 (602.5950908660889 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=852287296, topics=[]) 09/22/2025 04:28:08.062 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 852287296 with 0 response partitions (1 implied) 09/22/2025 04:28:08.062 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 684 09/22/2025 04:28:08.062 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 09/22/2025 04:28:08.062 7fb4319d17c0 [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)]) 09/22/2025 04:28:08.062 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:08.062 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7395, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:08.062 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7414 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7395, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:08.063 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204190.136475, idle connection 143258.000000, request 304999.946117 09/22/2025 04:28:08.063 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204189.508789, idle connection 143258.000000, request 304999.320984 09/22/2025 04:28:08.162 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207995.620361, idle connection 146334.000000, request 304397.962570 09/22/2025 04:28:08.162 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7681 09/22/2025 04:28:08.162 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:08.163 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7681 (602.8826236724854 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1462912714, topics=[]) 09/22/2025 04:28:08.163 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1462912714 with 0 response partitions (1 implied) 09/22/2025 04:28:08.185 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203567.366211, idle connection 142690.000000, request 304398.358107 09/22/2025 04:28:08.185 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7375 09/22/2025 04:28:08.185 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:08.186 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7375 (602.3163795471191 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1196783146, topics=[]) 09/22/2025 04:28:08.186 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1196783146 with 0 response partitions (1 implied) 09/22/2025 04:28:08.333 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207266.709961, idle connection 384454.000000, request 304398.511648 09/22/2025 04:28:08.334 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7955 09/22/2025 04:28:08.334 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:08.334 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7955 (602.3173332214355 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=427376601, topics=[]) 09/22/2025 04:28:08.335 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 427376601 with 0 response partitions (1 implied) 09/22/2025 04:28:08.663 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 7451 09/22/2025 04:28:08.664 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/22/2025 04:28:08.664 7fb43448cea0 [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)]) 09/22/2025 04:28:08.664 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:08.664 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8209, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:08.664 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 8224 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8209, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:08.664 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 202097.696289, idle connection 140606.000000, request 304999.929190 09/22/2025 04:28:08.665 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 203588.189453, idle connection 142656.000000, request 304398.002148 09/22/2025 04:28:08.665 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 202096.962402, idle connection 140605.000000, request 304999.208212 09/22/2025 04:28:08.665 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7414 09/22/2025 04:28:08.665 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:08.665 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7414 (602.851390838623 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1827457778, topics=[]) 09/22/2025 04:28:08.666 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1827457778 with 0 response partitions (1 implied) 09/22/2025 04:28:08.764 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 2381 09/22/2025 04:28:08.764 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/22/2025 04:28:08.765 7fb431fbd040 [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)]) 09/22/2025 04:28:08.765 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:08.765 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7666, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:08.765 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7682 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7666, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:08.765 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207392.116943, idle connection 145730.000000, request 304999.934435 09/22/2025 04:28:08.766 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 207391.557861, idle connection 145730.000000, request 304999.385834 09/22/2025 04:28:08.786 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 288 09/22/2025 04:28:08.787 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 09/22/2025 04:28:08.787 7fb43448cf40 [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)]) 09/22/2025 04:28:08.787 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:08.787 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7366, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:08.787 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7376 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7366, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:08.787 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 202964.842041, idle connection 142088.000000, request 304999.931812 09/22/2025 04:28:08.788 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 202964.299561, idle connection 142087.000000, request 304999.400854 09/22/2025 04:28:08.937 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4776 09/22/2025 04:28:08.937 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/22/2025 04:28:08.937 7fb431fdb400 [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)]) 09/22/2025 04:28:08.937 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:08.937 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7939, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:08.937 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7956 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7939, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:08.938 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206662.566162, idle connection 383850.000000, request 304999.916553 09/22/2025 04:28:08.938 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206661.982910, idle connection 383850.000000, request 304999.351978 09/22/2025 04:28:09.266 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 684 09/22/2025 04:28:09.267 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 09/22/2025 04:28:09.267 7fb4319d17c0 [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)]) 09/22/2025 04:28:09.267 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:09.267 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7396, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:09.267 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7415 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7396, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:09.267 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 202985.488770, idle connection 142054.000000, request 304999.932766 09/22/2025 04:28:09.268 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 201494.337646, idle connection 140002.000000, request 304396.580219 09/22/2025 04:28:09.268 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 202984.779053, idle connection 142053.000000, request 304999.235392 09/22/2025 04:28:09.268 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8224 09/22/2025 04:28:09.268 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:09.269 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 8224 (604.2516231536865 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=852287296, topics=[]) 09/22/2025 04:28:09.269 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 852287296 with 0 response partitions (1 implied) 09/22/2025 04:28:09.367 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206790.046631, idle connection 145128.000000, request 304397.865057 09/22/2025 04:28:09.368 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7682 09/22/2025 04:28:09.368 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:09.368 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7682 (602.8378009796143 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1462912714, topics=[]) 09/22/2025 04:28:09.368 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1462912714 with 0 response partitions (1 implied) 09/22/2025 04:28:09.390 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 202362.786621, idle connection 141486.000000, request 304397.876740 09/22/2025 04:28:09.390 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7376 09/22/2025 04:28:09.390 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:09.390 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7376 (602.7498245239258 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1196783146, topics=[]) 09/22/2025 04:28:09.390 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1196783146 with 0 response partitions (1 implied) 09/22/2025 04:28:09.539 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206061.096191, idle connection 383249.000000, request 304398.455381 09/22/2025 04:28:09.540 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7956 09/22/2025 04:28:09.540 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:09.540 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7956 (602.2450923919678 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=427376601, topics=[]) 09/22/2025 04:28:09.540 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 427376601 with 0 response partitions (1 implied) 09/22/2025 04:28:09.869 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 7451 09/22/2025 04:28:09.869 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/22/2025 04:28:09.870 7fb43448cea0 [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)]) 09/22/2025 04:28:09.870 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:09.870 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8210, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:09.870 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 8225 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8210, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:09.870 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 200891.748047, idle connection 139400.000000, request 304999.930382 09/22/2025 04:28:09.871 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 202382.249756, idle connection 141450.000000, request 304396.689415 09/22/2025 04:28:09.871 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 200890.995850, idle connection 139399.000000, request 304999.189615 09/22/2025 04:28:09.871 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7415 09/22/2025 04:28:09.871 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:09.871 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7415 (604.2180061340332 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1827457778, topics=[]) 09/22/2025 04:28:09.872 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1827457778 with 0 response partitions (1 implied) 09/22/2025 04:28:09.969 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 2381 09/22/2025 04:28:09.969 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/22/2025 04:28:09.970 7fb431fbd040 [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)]) 09/22/2025 04:28:09.970 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:09.970 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7667, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:09.970 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7683 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7667, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:09.970 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206187.131836, idle connection 144525.000000, request 304999.933481 09/22/2025 04:28:09.971 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 206186.588623, idle connection 144525.000000, request 304999.401569 09/22/2025 04:28:09.991 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 288 09/22/2025 04:28:09.992 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 09/22/2025 04:28:09.992 7fb43448cf40 [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)]) 09/22/2025 04:28:09.992 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:09.992 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7367, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:09.992 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7377 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7367, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:09.992 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 201759.841797, idle connection 140883.000000, request 304999.918461 09/22/2025 04:28:09.993 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 201759.262695, idle connection 140882.000000, request 304999.357700 09/22/2025 04:28:10.141 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4776 09/22/2025 04:28:10.141 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/22/2025 04:28:10.142 7fb431fdb400 [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)]) 09/22/2025 04:28:10.142 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:10.142 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7940, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:10.142 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7957 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7940, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:10.142 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205458.055420, idle connection 382646.000000, request 304999.933243 09/22/2025 04:28:10.143 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205457.540039, idle connection 382645.000000, request 304999.428511 09/22/2025 04:28:10.472 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 684 09/22/2025 04:28:10.473 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 09/22/2025 04:28:10.473 7fb4319d17c0 [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)]) 09/22/2025 04:28:10.473 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:10.473 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7397, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:10.473 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7416 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7397, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:10.473 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 201779.580078, idle connection 140848.000000, request 304999.933958 09/22/2025 04:28:10.474 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 200288.424072, idle connection 138796.000000, request 304396.616936 09/22/2025 04:28:10.474 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 201778.857178, idle connection 140847.000000, request 304999.221325 09/22/2025 04:28:10.474 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8225 09/22/2025 04:28:10.474 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:10.474 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 8225 (604.1984558105469 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=852287296, topics=[]) 09/22/2025 04:28:10.475 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 852287296 with 0 response partitions (1 implied) 09/22/2025 04:28:10.572 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 205585.436279, idle connection 143924.000000, request 304398.238420 09/22/2025 04:28:10.572 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7683 09/22/2025 04:28:10.572 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:10.573 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7683 (602.6287078857422 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1462912714, topics=[]) 09/22/2025 04:28:10.573 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1462912714 with 0 response partitions (1 implied) 09/22/2025 04:28:10.594 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 201158.113037, idle connection 140281.000000, request 304398.194551 09/22/2025 04:28:10.595 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7377 09/22/2025 04:28:10.595 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:10.595 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7377 (602.4928092956543 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1196783146, topics=[]) 09/22/2025 04:28:10.595 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1196783146 with 0 response partitions (1 implied) 09/22/2025 04:28:10.744 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204856.654541, idle connection 382044.000000, request 304398.530006 09/22/2025 04:28:10.744 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7957 09/22/2025 04:28:10.744 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:10.744 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7957 (602.2827625274658 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=427376601, topics=[]) 09/22/2025 04:28:10.745 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 427376601 with 0 response partitions (1 implied) 09/22/2025 04:28:11.075 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 7451 09/22/2025 04:28:11.075 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 09/22/2025 04:28:11.075 7fb43448cea0 [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)]) 09/22/2025 04:28:11.076 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:11.076 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8211, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:11.076 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 8226 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=852287296, session_epoch=8211, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:11.076 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 199685.734619, idle connection 138194.000000, request 304999.921560 09/22/2025 04:28:11.077 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 201176.087158, idle connection 140244.000000, request 304396.442652 09/22/2025 04:28:11.077 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 199684.649170, idle connection 138193.000000, request 304998.846769 09/22/2025 04:28:11.078 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 7416 09/22/2025 04:28:11.078 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:11.078 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 7416 (604.6919822692871 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1827457778, topics=[]) 09/22/2025 04:28:11.078 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1827457778 with 0 response partitions (1 implied) 09/22/2025 04:28:11.174 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 2381 09/22/2025 04:28:11.174 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 09/22/2025 04:28:11.174 7fb431fbd040 [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)]) 09/22/2025 04:28:11.174 7fb431fbd040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:11.174 7fb431fbd040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7668, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:11.174 7fb431fbd040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7684 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1462912714, session_epoch=7668, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:11.175 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204982.635010, idle connection 143321.000000, request 304999.920607 09/22/2025 04:28:11.175 7fb431fbd040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204982.072266, idle connection 143320.000000, request 304999.370337 09/22/2025 04:28:11.196 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 288 09/22/2025 04:28:11.196 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 09/22/2025 04:28:11.196 7fb43448cf40 [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)]) 09/22/2025 04:28:11.196 7fb43448cf40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:11.197 7fb43448cf40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7368, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:11.197 7fb43448cf40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7378 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1196783146, session_epoch=7368, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:11.197 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 200555.336670, idle connection 139678.000000, request 304999.935389 09/22/2025 04:28:11.197 7fb43448cf40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 200554.771973, idle connection 139678.000000, request 304999.380112 09/22/2025 04:28:11.346 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 4776 09/22/2025 04:28:11.346 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 09/22/2025 04:28:11.346 7fb431fdb400 [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)]) 09/22/2025 04:28:11.346 7fb431fdb400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:11.347 7fb431fdb400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7941, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:11.347 7fb431fdb400 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7958 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=427376601, session_epoch=7941, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:11.347 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204253.302490, idle connection 381441.000000, request 304999.931812 09/22/2025 04:28:11.348 7fb431fdb400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 204252.647461, idle connection 381440.000000, request 304999.283075 09/22/2025 04:28:11.679 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 684 09/22/2025 04:28:11.679 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 09/22/2025 04:28:11.679 7fb4319d17c0 [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)]) 09/22/2025 04:28:11.679 7fb4319d17c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 09/22/2025 04:28:11.679 7fb4319d17c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7398, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:11.680 7fb4319d17c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Request 7417 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1827457778, session_epoch=7398, topics=[], forgotten_topics_data=[]) 09/22/2025 04:28:11.680 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 200572.935303, idle connection 139641.000000, request 304999.936581 09/22/2025 04:28:11.680 7fb43448cea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 199081.786621, idle connection 137590.000000, request 304395.986080 09/22/2025 04:28:11.681 7fb4319d17c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 200572.196289, idle connection 139640.000000, request 304999.209404 09/22/2025 04:28:11.681 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 8226 09/22/2025 04:28:11.681 7fb43448cea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 09/22/2025 04:28:11.681 7fb43448cea0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.56', 9092)]>: Response 8226 (604.8641204833984 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=852287296, topics=[]) 09/22/2025 04:28:11.681 7fb43448cea0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 852287296 with 0 response partitions (1 implied)