05/05/2025 02:11:53.905 7f578b4a50f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 476 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1369124269, session_epoch=473, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:53.905 7f578b4a50f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62622.023438, idle connection 1752.000000, request 304999.938726 05/05/2025 02:11:53.906 7f578b4a50f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62621.439209, idle connection 1752.000000, request 304999.364614 05/05/2025 02:11:53.942 7f578b7a42e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 16 05/05/2025 02:11:53.942 7f578b7a42e8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 05/05/2025 02:11:53.942 7f578b7a42e8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 05/05/2025 02:11:53.943 7f578b7a42e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:53.943 7f578b7a42e8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1754878510, session_epoch=451, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:53.943 7f578b7a42e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 454 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1754878510, session_epoch=451, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:53.943 7f578b7a42e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63368.676758, idle connection 1752.000000, request 304999.944925 05/05/2025 02:11:53.943 7f578b7a42e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63368.166016, idle connection 1751.000000, request 304999.443769 05/05/2025 02:11:53.957 7f578afd6390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 21 05/05/2025 02:11:53.958 7f578afd6390 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 05/05/2025 02:11:53.958 7f578afd6390 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 05/05/2025 02:11:53.958 7f578afd6390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:53.958 7f578afd6390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1604738415, session_epoch=452, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:53.958 7f578afd6390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 455 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1604738415, session_epoch=452, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:53.958 7f578afd6390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62622.393799, idle connection 1934.000000, request 304999.951839 05/05/2025 02:11:53.958 7f578afd6390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62621.952637, idle connection 1933.000000, request 304999.515057 05/05/2025 02:11:53.961 7f578b42d2e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62847.012695, idle connection 1832.000000, request 304398.283243 05/05/2025 02:11:53.962 7f578b42d2e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 451 05/05/2025 02:11:53.962 7f578b42d2e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:53.962 7f578b42d2e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 451 (602.1568775177002 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=739843525, topics=[]) 05/05/2025 02:11:53.962 7f578b42d2e8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 739843525 with 0 response partitions (1 implied) 05/05/2025 02:11:53.962 7f578adb42e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63590.119385, idle connection 2158.000000, request 304398.180723 05/05/2025 02:11:53.962 7f578adb42e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 482 05/05/2025 02:11:53.962 7f578adb42e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:53.963 7f578adb42e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 482 (602.1938323974609 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1209576856, topics=[]) 05/05/2025 02:11:53.963 7f578adb42e8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1209576856 with 0 response partitions (1 implied) 05/05/2025 02:11:54.069 7f578b3d26d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63366.247314, idle connection 1973.000000, request 304398.921490 05/05/2025 02:11:54.070 7f578b3d26d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 474 05/05/2025 02:11:54.070 7f578b3d26d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:54.070 7f578b3d26d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 474 (601.649284362793 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=522221117, topics=[]) 05/05/2025 02:11:54.070 7f578b3d26d8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 522221117 with 0 response partitions (1 implied) 05/05/2025 02:11:54.099 7f5796863cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 05/05/2025 02:11:54.100 7f5796863cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 05/05/2025 02:11:54.100 7f5796863cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)]) 05/05/2025 02:11:54.100 7f5796863cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:54.100 7f5796863cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1265972283, session_epoch=447, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.100 7f5796863cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 450 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1265972283, session_epoch=447, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.100 7f5796863cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62314.480957, idle connection 1544.000000, request 304999.946833 05/05/2025 02:11:54.100 7f578b3a9cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 05/05/2025 02:11:54.101 7f578b3a9cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 05/05/2025 02:11:54.101 7f578b3a9cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 05/05/2025 02:11:54.101 7f578b3a9cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:54.101 7f578b3a9cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=286255758, session_epoch=447, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.101 7f578b3a9cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 450 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=286255758, session_epoch=447, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.101 7f578b3a9cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62340.596924, idle connection 1584.000000, request 304999.958515 05/05/2025 02:11:54.101 7f578b3e1828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63281.269531, idle connection 1600.000000, request 304396.719694 05/05/2025 02:11:54.102 7f5796863cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62313.174805, idle connection 1543.000000, request 304998.650312 05/05/2025 02:11:54.102 7f578b3e1828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 455 05/05/2025 02:11:54.102 7f578b3e1828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:54.102 7f578b3e1828 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 455 (604.006290435791 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1889094295, topics=[]) 05/05/2025 02:11:54.102 7f578b3e1828 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1889094295 with 0 response partitions (1 implied) 05/05/2025 02:11:54.102 7f578b3a9cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62339.174561, idle connection 1582.000000, request 304998.541117 05/05/2025 02:11:54.105 7f578ae92d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 33 05/05/2025 02:11:54.105 7f578ae92d68 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 05/05/2025 02:11:54.105 7f578ae92d68 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 05/05/2025 02:11:54.105 7f578ae92d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:54.105 7f578ae92d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=390896471, session_epoch=454, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.105 7f578ae92d68 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 457 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=390896471, session_epoch=454, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.105 7f578ae92d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63471.685547, idle connection 1926.000000, request 304999.961853 05/05/2025 02:11:54.106 7f578ae92d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63471.351318, idle connection 1925.000000, request 304999.631643 05/05/2025 02:11:54.112 7f578b28c240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 76 05/05/2025 02:11:54.112 7f578b28c240 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 05/05/2025 02:11:54.112 7f578b28c240 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 05/05/2025 02:11:54.112 7f578b28c240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:54.112 7f578b28c240 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1799898802, session_epoch=463, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.113 7f578b28c240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 466 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1799898802, session_epoch=463, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.113 7f578b28c240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63553.623291, idle connection 1751.000000, request 304999.958992 05/05/2025 02:11:54.113 7f578b28c240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63553.289551, idle connection 1751.000000, request 304999.631166 05/05/2025 02:11:54.176 7f578afe4828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 68 05/05/2025 02:11:54.177 7f578afe4828 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 05/05/2025 02:11:54.177 7f578afe4828 [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)]) 05/05/2025 02:11:54.177 7f578afe4828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:54.177 7f578afe4828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1087803404, session_epoch=461, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.177 7f578afe4828 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 464 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1087803404, session_epoch=461, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.177 7f578afe4828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62843.052246, idle connection 1811.000000, request 304999.944210 05/05/2025 02:11:54.178 7f578afe4828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62842.548340, idle connection 1811.000000, request 304999.448299 05/05/2025 02:11:54.178 7f578b43e0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 40 05/05/2025 02:11:54.178 7f578b43e0f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 05/05/2025 02:11:54.178 7f578b43e0f0 [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)]) 05/05/2025 02:11:54.178 7f578b43e0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:54.178 7f578b43e0f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2034123924, session_epoch=455, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.178 7f578b43e0f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 458 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2034123924, session_epoch=455, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.179 7f578b43e0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62672.986816, idle connection 1749.000000, request 304999.957800 05/05/2025 02:11:54.179 7f578b43e0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62672.584473, idle connection 1748.000000, request 304999.559402 05/05/2025 02:11:54.224 7f578af15f60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62918.607910, idle connection 1732.000000, request 304397.253275 05/05/2025 02:11:54.224 7f578af15f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 496 05/05/2025 02:11:54.224 7f578af15f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:54.224 7f578af15f60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 496 (603.2960414886475 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=546626154, topics=[]) 05/05/2025 02:11:54.225 7f578af15f60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 546626154 with 0 response partitions (1 implied) 05/05/2025 02:11:54.225 7f578b4a0e10 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62349.969727, idle connection 1416.000000, request 304397.785425 05/05/2025 02:11:54.225 7f578b4a0e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 671 05/05/2025 02:11:54.225 7f578b4a0e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:54.225 7f578b4a0e10 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 671 (602.6017665863037 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2017973102, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2366, last_stable_offset=2366, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\t=\x00\x00\x01\x04\x00\x00\x00\x00\x02.>\x84\x92\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 05/05/2025 02:11:54.225 7f578b4a0e10 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2017973102 with 1 response partitions (0 implied) 05/05/2025 02:11:54.226 7f578b4a0e10 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 2365 05/05/2025 02:11:54.226 7f578b4a0e10 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 2365 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 05/05/2025 02:11:54.226 7f578b4a0e10 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 2366 (leader epoch 0) 05/05/2025 02:11:54.233 7f578b476d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62178.386475, idle connection 1511.000000, request 304399.209261 05/05/2025 02:11:54.233 7f578b476d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 456 05/05/2025 02:11:54.233 7f578b476d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:54.234 7f578b476d68 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 456 (601.2048721313477 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1394807976, topics=[]) 05/05/2025 02:11:54.234 7f578b476d68 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1394807976 with 0 response partitions (1 implied) 05/05/2025 02:11:54.273 7f578b3eb978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 21 05/05/2025 02:11:54.273 7f578b3eb978 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 05/05/2025 02:11:54.273 7f578b3eb978 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 05/05/2025 02:11:54.273 7f578b3eb978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:54.273 7f578b3eb978 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=892475593, session_epoch=454, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.273 7f578b3eb978 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 457 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=892475593, session_epoch=454, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.273 7f578b3eb978 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62700.034912, idle connection 1447.000000, request 304999.950409 05/05/2025 02:11:54.274 7f578b3eb978 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62699.627930, idle connection 1446.000000, request 304999.551296 05/05/2025 02:11:54.278 7f578b4bbc18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 45 05/05/2025 02:11:54.278 7f578b4bbc18 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 05/05/2025 02:11:54.278 7f578b4bbc18 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 05/05/2025 02:11:54.278 7f578b4bbc18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:54.278 7f578b4bbc18 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1438358457, session_epoch=459, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.278 7f578b4bbc18 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 462 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1438358457, session_epoch=459, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.278 7f578b4bbc18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63178.791992, idle connection 1573.000000, request 304999.959946 05/05/2025 02:11:54.278 7f578b41e630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 17 05/05/2025 02:11:54.278 7f578b41e630 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 05/05/2025 02:11:54.278 7f578b41e630 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)]) 05/05/2025 02:11:54.279 7f578b41e630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:54.279 7f578b41e630 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=349838626, session_epoch=453, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.279 7f578b41e630 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 456 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=349838626, session_epoch=453, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.279 7f578b41e630 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63129.114990, idle connection 1503.000000, request 304999.962330 05/05/2025 02:11:54.279 7f578b4bbc18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63177.800781, idle connection 1572.000000, request 304998.972654 05/05/2025 02:11:54.280 7f578b41e630 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63128.380615, idle connection 1502.000000, request 304999.231577 05/05/2025 02:11:54.283 7f578b42d438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62961.949951, idle connection 1542.000000, request 304397.320747 05/05/2025 02:11:54.284 7f578b42d438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 455 05/05/2025 02:11:54.284 7f578b42d438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:54.284 7f578b42d438 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 455 (603.071928024292 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=170483227, topics=[]) 05/05/2025 02:11:54.284 7f578b42d438 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 170483227 with 0 response partitions (1 implied) 05/05/2025 02:11:54.284 7f578b46f048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63176.201416, idle connection 1527.000000, request 304397.251606 05/05/2025 02:11:54.284 7f578b46f048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 455 05/05/2025 02:11:54.284 7f578b46f048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:54.285 7f578b46f048 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 455 (603.0623912811279 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=270212331, topics=[]) 05/05/2025 02:11:54.285 7f578b46f048 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 270212331 with 0 response partitions (1 implied) 05/05/2025 02:11:54.285 7f578b41d588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63285.413574, idle connection 1658.000000, request 304397.605896 05/05/2025 02:11:54.285 7f578b444d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62846.702881, idle connection 1777.000000, request 304398.493290 05/05/2025 02:11:54.285 7f578b41d588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 486 05/05/2025 02:11:54.285 7f578b41d588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:54.285 7f578b41d588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 486 (602.8311252593994 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1679627920, topics=[]) 05/05/2025 02:11:54.285 7f578b41d588 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1679627920 with 0 response partitions (1 implied) 05/05/2025 02:11:54.286 7f578b444d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 474 05/05/2025 02:11:54.286 7f578b444d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:54.286 7f578b444d68 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 474 (602.2844314575195 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1801466066, topics=[]) 05/05/2025 02:11:54.286 7f578b444d68 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1801466066 with 0 response partitions (1 implied) 05/05/2025 02:11:54.327 7f578b4a0e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2366 05/05/2025 02:11:54.327 7f578b4a0e10 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 05/05/2025 02:11:54.327 7f578b4a0e10 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 05/05/2025 02:11:54.327 7f578b4a0e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:54.327 7f578b4a0e10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2017973102, session_epoch=669, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=2366, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 05/05/2025 02:11:54.327 7f578b4a0e10 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 672 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2017973102, session_epoch=669, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=2366, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 05/05/2025 02:11:54.328 7f578b4a0e10 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62247.227051, idle connection 1313.000000, request 304999.926805 05/05/2025 02:11:54.328 7f578b4a0e10 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62246.595703, idle connection 1313.000000, request 304999.306440 05/05/2025 02:11:54.384 7f578b4c7438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63273.743652, idle connection 1451.000000, request 304398.944139 05/05/2025 02:11:54.384 7f578b4c7438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 460 05/05/2025 02:11:54.384 7f578b4c7438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:54.384 7f578b4c7438 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 460 (601.6004085540771 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1278798477, topics=[]) 05/05/2025 02:11:54.384 7f578b4c7438 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1278798477 with 0 response partitions (1 implied) 05/05/2025 02:11:54.400 7f578b4bb048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62481.791260, idle connection 1333.000000, request 304399.087906 05/05/2025 02:11:54.400 7f578b4bb048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 454 05/05/2025 02:11:54.400 7f578b4bb048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:54.400 7f578b4bb048 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 454 (601.3896465301514 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=182402792, topics=[]) 05/05/2025 02:11:54.401 7f578b4bb048 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 182402792 with 0 response partitions (1 implied) 05/05/2025 02:11:54.406 7f578b25a588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 63444.445557, idle connection 1692.000000, request 304398.850918 05/05/2025 02:11:54.406 7f578b25a588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 478 05/05/2025 02:11:54.406 7f578b25a588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:54.406 7f578b25a588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 478 (601.5586853027344 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1554889754, topics=[]) 05/05/2025 02:11:54.406 7f578b25a588 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1554889754 with 0 response partitions (1 implied) 05/05/2025 02:11:54.430 7f578aefbcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 163 05/05/2025 02:11:54.430 7f578aefbcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 05/05/2025 02:11:54.430 7f578aefbcc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 05/05/2025 02:11:54.430 7f578aefbcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:54.430 7f578aefbcc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=277208274, session_epoch=474, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.430 7f578aefbcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 477 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=277208274, session_epoch=474, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.431 7f578aefbcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62521.160400, idle connection 1640.000000, request 304999.948740 05/05/2025 02:11:54.431 7f578b4a1828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62856.788086, idle connection 1479.000000, request 304397.641659 05/05/2025 02:11:54.431 7f578aefbcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62520.603271, idle connection 1640.000000, request 304999.401331 05/05/2025 02:11:54.431 7f578b4a1828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 454 05/05/2025 02:11:54.431 7f578b4a1828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:54.431 7f578b4a1828 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 454 (603.0917167663574 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=287674646, topics=[]) 05/05/2025 02:11:54.432 7f578b4a1828 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 287674646 with 0 response partitions (1 implied) 05/05/2025 02:11:54.449 7f578aea1198 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62541.669678, idle connection 1509.000000, request 304399.105549 05/05/2025 02:11:54.449 7f578aea1198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 484 05/05/2025 02:11:54.449 7f578aea1198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:54.449 7f578aea1198 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 484 (601.3729572296143 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1832307886, topics=[]) 05/05/2025 02:11:54.450 7f578aea1198 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1832307886 with 0 response partitions (1 implied) 05/05/2025 02:11:54.454 7f578b3c8d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 12 05/05/2025 02:11:54.454 7f578b3c8d68 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 05/05/2025 02:11:54.454 7f578b3c8d68 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 05/05/2025 02:11:54.454 7f578b3c8d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:54.454 7f578b3c8d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1877425480, session_epoch=451, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.455 7f578b3c8d68 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 454 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1877425480, session_epoch=451, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.455 7f578b3c8d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62351.652100, idle connection 1306.000000, request 304999.957085 05/05/2025 02:11:54.455 7f578b3c8d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62351.276611, idle connection 1306.000000, request 304999.586105 05/05/2025 02:11:54.507 7f578b4a50f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62020.893799, idle connection 1151.000000, request 304398.808241 05/05/2025 02:11:54.507 7f578b4a50f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 476 05/05/2025 02:11:54.507 7f578b4a50f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:54.507 7f578b4a50f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 476 (601.722002029419 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1369124269, topics=[]) 05/05/2025 02:11:54.507 7f578b4a50f0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1369124269 with 0 response partitions (1 implied) 05/05/2025 02:11:54.544 7f578b7a42e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62767.567139, idle connection 1150.000000, request 304398.835421 05/05/2025 02:11:54.544 7f578b7a42e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 454 05/05/2025 02:11:54.545 7f578b7a42e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:54.545 7f578b7a42e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 454 (601.6645431518555 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1754878510, topics=[]) 05/05/2025 02:11:54.545 7f578b7a42e8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1754878510 with 0 response partitions (1 implied) 05/05/2025 02:11:54.559 7f578afd6390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62021.511475, idle connection 1333.000000, request 304399.066448 05/05/2025 02:11:54.559 7f578afd6390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 455 05/05/2025 02:11:54.559 7f578afd6390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:54.559 7f578afd6390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 455 (601.3765335083008 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1604738415, topics=[]) 05/05/2025 02:11:54.560 7f578afd6390 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1604738415 with 0 response partitions (1 implied) 05/05/2025 02:11:54.563 7f578b42d2e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 4 05/05/2025 02:11:54.563 7f578b42d2e8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 05/05/2025 02:11:54.563 7f578b42d2e8 [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)]) 05/05/2025 02:11:54.563 7f578b42d2e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:54.563 7f578b42d2e8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=739843525, session_epoch=449, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.563 7f578b42d2e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 452 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=739843525, session_epoch=449, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.563 7f578b42d2e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62244.964355, idle connection 1230.000000, request 304999.953985 05/05/2025 02:11:54.564 7f578adb42e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 225 05/05/2025 02:11:54.564 7f578adb42e8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 05/05/2025 02:11:54.564 7f578adb42e8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 05/05/2025 02:11:54.564 7f578adb42e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:54.564 7f578adb42e8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1209576856, session_epoch=480, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.564 7f578adb42e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 483 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1209576856, session_epoch=480, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.564 7f578adb42e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62988.140137, idle connection 1556.000000, request 304999.961615 05/05/2025 02:11:54.565 7f578b42d2e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62243.830078, idle connection 1229.000000, request 304998.826265 05/05/2025 02:11:54.565 7f578adb42e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62987.436523, idle connection 1555.000000, request 304999.262571 05/05/2025 02:11:54.671 7f578b3d26d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 90 05/05/2025 02:11:54.671 7f578b3d26d8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 05/05/2025 02:11:54.671 7f578b3d26d8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 05/05/2025 02:11:54.671 7f578b3d26d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:54.671 7f578b3d26d8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=522221117, session_epoch=472, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.671 7f578b3d26d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 475 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=522221117, session_epoch=472, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.672 7f578b3d26d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62763.998291, idle connection 1371.000000, request 304999.922037 05/05/2025 02:11:54.672 7f578b3d26d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62763.335449, idle connection 1370.000000, request 304999.269724 05/05/2025 02:11:54.702 7f578b3e1828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 19 05/05/2025 02:11:54.703 7f578b3e1828 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 05/05/2025 02:11:54.703 7f578b3e1828 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 05/05/2025 02:11:54.703 7f578b3e1828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:54.703 7f578b3e1828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1889094295, session_epoch=453, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.703 7f578b3e1828 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 456 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1889094295, session_epoch=453, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.703 7f578b3e1828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62679.180420, idle connection 998.000000, request 304999.941587 05/05/2025 02:11:54.704 7f5796863cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61711.155029, idle connection 941.000000, request 304396.626949 05/05/2025 02:11:54.704 7f578b3a9cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61737.883545, idle connection 981.000000, request 304397.248507 05/05/2025 02:11:54.704 7f578b3e1828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62678.406982, idle connection 998.000000, request 304999.179363 05/05/2025 02:11:54.704 7f5796863cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 450 05/05/2025 02:11:54.704 7f5796863cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:54.705 7f5796863cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 450 (604.3391227722168 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1265972283, topics=[]) 05/05/2025 02:11:54.705 7f5796863cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1265972283 with 0 response partitions (1 implied) 05/05/2025 02:11:54.705 7f578b3a9cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 450 05/05/2025 02:11:54.705 7f578b3a9cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:54.705 7f578b3a9cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 450 (604.109525680542 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=286255758, topics=[]) 05/05/2025 02:11:54.705 7f578b3a9cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 286255758 with 0 response partitions (1 implied) 05/05/2025 02:11:54.706 7f578ae92d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62871.053467, idle connection 1325.000000, request 304399.331331 05/05/2025 02:11:54.706 7f578ae92d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 457 05/05/2025 02:11:54.706 7f578ae92d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:54.706 7f578ae92d68 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 457 (601.006031036377 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=390896471, topics=[]) 05/05/2025 02:11:54.706 7f578ae92d68 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 390896471 with 0 response partitions (1 implied) 05/05/2025 02:11:54.713 7f578b28c240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62952.932861, idle connection 1151.000000, request 304399.271488 05/05/2025 02:11:54.714 7f578b28c240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 466 05/05/2025 02:11:54.714 7f578b28c240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:54.714 7f578b28c240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 466 (601.0489463806152 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1799898802, topics=[]) 05/05/2025 02:11:54.714 7f578b28c240 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1799898802 with 0 response partitions (1 implied) 05/05/2025 02:11:54.780 7f578afe4828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62240.701660, idle connection 1209.000000, request 304397.591352 05/05/2025 02:11:54.780 7f578afe4828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 464 05/05/2025 02:11:54.780 7f578afe4828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:54.780 7f578afe4828 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 464 (602.9996871948242 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1087803404, topics=[]) 05/05/2025 02:11:54.780 7f578afe4828 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1087803404 with 0 response partitions (1 implied) 05/05/2025 02:11:54.781 7f578b43e0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62070.803223, idle connection 1147.000000, request 304397.773504 05/05/2025 02:11:54.781 7f578b43e0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 458 05/05/2025 02:11:54.781 7f578b43e0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:54.781 7f578b43e0f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 458 (602.5786399841309 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2034123924, topics=[]) 05/05/2025 02:11:54.781 7f578b43e0f0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2034123924 with 0 response partitions (1 implied) 05/05/2025 02:11:54.825 7f578af15f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 219 05/05/2025 02:11:54.825 7f578af15f60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 05/05/2025 02:11:54.825 7f578af15f60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 05/05/2025 02:11:54.825 7f578af15f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:54.825 7f578af15f60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=546626154, session_epoch=494, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.826 7f578af15f60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 497 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=546626154, session_epoch=494, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.826 7f578af15f60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62316.729736, idle connection 1130.000000, request 304999.941587 05/05/2025 02:11:54.826 7f578af15f60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62316.247803, idle connection 1130.000000, request 304999.469995 05/05/2025 02:11:54.834 7f578b476d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 17 05/05/2025 02:11:54.834 7f578b476d68 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 05/05/2025 02:11:54.834 7f578b476d68 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 05/05/2025 02:11:54.834 7f578b476d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:54.834 7f578b476d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1394807976, session_epoch=454, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.835 7f578b476d68 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 457 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1394807976, session_epoch=454, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.835 7f578b476d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61576.881104, idle connection 909.000000, request 304999.956608 05/05/2025 02:11:54.835 7f578b476d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61576.507812, idle connection 909.000000, request 304999.587536 05/05/2025 02:11:54.874 7f578b3eb978 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62099.073730, idle connection 846.000000, request 304398.978949 05/05/2025 02:11:54.875 7f578b3eb978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 457 05/05/2025 02:11:54.875 7f578b3eb978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:54.875 7f578b3eb978 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 457 (601.5808582305908 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=892475593, topics=[]) 05/05/2025 02:11:54.875 7f578b3eb978 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 892475593 with 0 response partitions (1 implied) 05/05/2025 02:11:54.880 7f578b4bbc18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62577.031738, idle connection 971.000000, request 304398.194313 05/05/2025 02:11:54.880 7f578b4bbc18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 462 05/05/2025 02:11:54.880 7f578b4bbc18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:54.880 7f578b4bbc18 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 462 (602.2171974182129 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1438358457, topics=[]) 05/05/2025 02:11:54.881 7f578b4bbc18 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1438358457 with 0 response partitions (1 implied) 05/05/2025 02:11:54.881 7f578b41e630 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62527.235107, idle connection 901.000000, request 304398.082495 05/05/2025 02:11:54.881 7f578b41e630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 456 05/05/2025 02:11:54.881 7f578b41e630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:54.881 7f578b41e630 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 456 (602.3383140563965 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=349838626, topics=[]) 05/05/2025 02:11:54.881 7f578b41e630 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 349838626 with 0 response partitions (1 implied) 05/05/2025 02:11:54.885 7f578b42d438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 28 05/05/2025 02:11:54.885 7f578b42d438 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 05/05/2025 02:11:54.885 7f578b42d438 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 05/05/2025 02:11:54.885 7f578b42d438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:54.885 7f578b42d438 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=170483227, session_epoch=453, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.885 7f578b42d438 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 456 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=170483227, session_epoch=453, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.885 7f578b42d438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62360.103271, idle connection 941.000000, request 304999.958515 05/05/2025 02:11:54.885 7f578b46f048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 23 05/05/2025 02:11:54.886 7f578b46f048 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 05/05/2025 02:11:54.886 7f578b46f048 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 05/05/2025 02:11:54.886 7f578b46f048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:54.886 7f578b46f048 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=270212331, session_epoch=453, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.886 7f578b46f048 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 456 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=270212331, session_epoch=453, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.886 7f578b46f048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62574.432617, idle connection 925.000000, request 304999.965191 05/05/2025 02:11:54.886 7f578b42d438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62359.080322, idle connection 940.000000, request 304998.939991 05/05/2025 02:11:54.886 7f578b41d588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 247 05/05/2025 02:11:54.887 7f578b41d588 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 05/05/2025 02:11:54.887 7f578b41d588 [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)]) 05/05/2025 02:11:54.887 7f578b41d588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:54.887 7f578b41d588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1679627920, session_epoch=484, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.887 7f578b41d588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 487 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1679627920, session_epoch=484, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.887 7f578b41d588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62683.249023, idle connection 1056.000000, request 304999.962568 05/05/2025 02:11:54.887 7f578b444d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 174 05/05/2025 02:11:54.887 7f578b444d68 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 05/05/2025 02:11:54.887 7f578b444d68 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 05/05/2025 02:11:54.887 7f578b444d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:54.887 7f578b444d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1801466066, session_epoch=472, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.888 7f578b444d68 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 475 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1801466066, session_epoch=472, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.888 7f578b444d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62244.031250, idle connection 1174.000000, request 304999.965906 05/05/2025 02:11:54.888 7f578b46f048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62572.457031, idle connection 923.000000, request 304997.993231 05/05/2025 02:11:54.888 7f578b41d588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62681.894531, idle connection 1054.000000, request 304998.611689 05/05/2025 02:11:54.889 7f578b444d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62243.000488, idle connection 1173.000000, request 304998.937607 05/05/2025 02:11:54.929 7f578b4a0e10 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61646.061035, idle connection 712.000000, request 304398.767471 05/05/2025 02:11:54.929 7f578b4a0e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 672 05/05/2025 02:11:54.929 7f578b4a0e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:54.929 7f578b4a0e10 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 672 (601.7646789550781 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2017973102, topics=[]) 05/05/2025 02:11:54.929 7f578b4a0e10 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2017973102 with 0 response partitions (1 implied) 05/05/2025 02:11:54.985 7f578b4c7438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 47 05/05/2025 02:11:54.985 7f578b4c7438 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 05/05/2025 02:11:54.985 7f578b4c7438 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)]) 05/05/2025 02:11:54.985 7f578b4c7438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:54.985 7f578b4c7438 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1278798477, session_epoch=458, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.985 7f578b4c7438 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 461 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1278798477, session_epoch=458, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:54.986 7f578b4c7438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62671.919678, idle connection 849.000000, request 304999.947309 05/05/2025 02:11:54.986 7f578b4c7438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62671.485840, idle connection 848.000000, request 304999.521732 05/05/2025 02:11:55.001 7f578b4bb048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 14 05/05/2025 02:11:55.001 7f578b4bb048 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 05/05/2025 02:11:55.001 7f578b4bb048 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 05/05/2025 02:11:55.001 7f578b4bb048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:55.001 7f578b4bb048 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=182402792, session_epoch=452, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.001 7f578b4bb048 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 455 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=182402792, session_epoch=452, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.001 7f578b4bb048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61880.165283, idle connection 731.000000, request 304999.953985 05/05/2025 02:11:55.002 7f578b4bb048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61879.788086, idle connection 731.000000, request 304999.582291 05/05/2025 02:11:55.008 7f578b25a588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 194 05/05/2025 02:11:55.008 7f578b25a588 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 05/05/2025 02:11:55.008 7f578b25a588 [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)]) 05/05/2025 02:11:55.008 7f578b25a588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:55.008 7f578b25a588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1554889754, session_epoch=476, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.008 7f578b25a588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 479 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1554889754, session_epoch=476, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.008 7f578b25a588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62842.108398, idle connection 1090.000000, request 304999.956131 05/05/2025 02:11:55.009 7f578b25a588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62841.762207, idle connection 1089.000000, request 304999.614477 05/05/2025 02:11:55.032 7f578b4a1828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 23 05/05/2025 02:11:55.032 7f578b4a1828 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 05/05/2025 02:11:55.032 7f578b4a1828 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)]) 05/05/2025 02:11:55.032 7f578b4a1828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:55.032 7f578b4a1828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=287674646, session_epoch=452, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.032 7f578b4a1828 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 455 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=287674646, session_epoch=452, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.033 7f578b4a1828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62254.967773, idle connection 877.000000, request 304999.954462 05/05/2025 02:11:55.033 7f578aefbcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61918.894287, idle connection 1038.000000, request 304397.689581 05/05/2025 02:11:55.033 7f578b4a1828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62254.453369, idle connection 876.000000, request 304999.447107 05/05/2025 02:11:55.033 7f578aefbcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 477 05/05/2025 02:11:55.033 7f578aefbcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:55.033 7f578aefbcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 477 (602.9908657073975 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=277208274, topics=[]) 05/05/2025 02:11:55.034 7f578aefbcc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 277208274 with 0 response partitions (1 implied) 05/05/2025 02:11:55.050 7f578aea1198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 137 05/05/2025 02:11:55.050 7f578aea1198 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 05/05/2025 02:11:55.050 7f578aea1198 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)]) 05/05/2025 02:11:55.050 7f578aea1198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:55.050 7f578aea1198 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1832307886, session_epoch=482, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.050 7f578aea1198 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 485 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1832307886, session_epoch=482, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.051 7f578aea1198 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61940.103760, idle connection 907.000000, request 304999.947548 05/05/2025 02:11:55.051 7f578aea1198 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61939.744385, idle connection 907.000000, request 304999.593735 05/05/2025 02:11:55.055 7f578b3c8d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61750.966309, idle connection 706.000000, request 304399.274588 05/05/2025 02:11:55.056 7f578b3c8d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 454 05/05/2025 02:11:55.056 7f578b3c8d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:55.056 7f578b3c8d68 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 454 (601.1018753051758 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1877425480, topics=[]) 05/05/2025 02:11:55.056 7f578b3c8d68 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1877425480 with 0 response partitions (1 implied) 05/05/2025 02:11:55.108 7f578b4a50f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 129 05/05/2025 02:11:55.108 7f578b4a50f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 05/05/2025 02:11:55.108 7f578b4a50f0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 05/05/2025 02:11:55.108 7f578b4a50f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:55.108 7f578b4a50f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1369124269, session_epoch=474, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.108 7f578b4a50f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 477 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1369124269, session_epoch=474, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.108 7f578b4a50f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61419.031738, idle connection 549.000000, request 304999.947071 05/05/2025 02:11:55.109 7f578b4a50f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61418.594238, idle connection 549.000000, request 304999.518394 05/05/2025 02:11:55.145 7f578b7a42e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 16 05/05/2025 02:11:55.145 7f578b7a42e8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 05/05/2025 02:11:55.145 7f578b7a42e8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 05/05/2025 02:11:55.145 7f578b7a42e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:55.146 7f578b7a42e8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1754878510, session_epoch=452, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.146 7f578b7a42e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 455 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1754878510, session_epoch=452, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.146 7f578b7a42e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62165.836426, idle connection 549.000000, request 304999.948740 05/05/2025 02:11:55.146 7f578b7a42e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62165.420898, idle connection 548.000000, request 304999.541759 05/05/2025 02:11:55.160 7f578afd6390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 21 05/05/2025 02:11:55.160 7f578afd6390 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 05/05/2025 02:11:55.160 7f578afd6390 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 05/05/2025 02:11:55.160 7f578afd6390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:55.160 7f578afd6390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1604738415, session_epoch=453, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.160 7f578afd6390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 456 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1604738415, session_epoch=453, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.161 7f578afd6390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61419.907227, idle connection 731.000000, request 304999.951124 05/05/2025 02:11:55.161 7f578afd6390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61419.492920, idle connection 731.000000, request 304999.536276 05/05/2025 02:11:55.165 7f578b42d2e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61643.120361, idle connection 629.000000, request 304398.113251 05/05/2025 02:11:55.166 7f578b42d2e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 452 05/05/2025 02:11:55.166 7f578b42d2e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:55.166 7f578b42d2e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 452 (602.2806167602539 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=739843525, topics=[]) 05/05/2025 02:11:55.166 7f578b42d2e8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 739843525 with 0 response partitions (1 implied) 05/05/2025 02:11:55.166 7f578adb42e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62386.300537, idle connection 954.000000, request 304398.122787 05/05/2025 02:11:55.166 7f578adb42e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 483 05/05/2025 02:11:55.166 7f578adb42e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:55.166 7f578adb42e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 483 (602.208137512207 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1209576856, topics=[]) 05/05/2025 02:11:55.166 7f578adb42e8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1209576856 with 0 response partitions (1 implied) 05/05/2025 02:11:55.273 7f578b3d26d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62162.657471, idle connection 770.000000, request 304398.587942 05/05/2025 02:11:55.273 7f578b3d26d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 475 05/05/2025 02:11:55.273 7f578b3d26d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:55.273 7f578b3d26d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 475 (601.9473075866699 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=522221117, topics=[]) 05/05/2025 02:11:55.274 7f578b3d26d8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 522221117 with 0 response partitions (1 implied) 05/05/2025 02:11:55.305 7f5796863cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 05/05/2025 02:11:55.305 7f5796863cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 05/05/2025 02:11:55.305 7f5796863cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)]) 05/05/2025 02:11:55.305 7f5796863cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:55.306 7f5796863cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1265972283, session_epoch=448, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.306 7f5796863cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 451 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1265972283, session_epoch=448, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.306 7f5796863cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61108.912842, idle connection 338.000000, request 304999.951124 05/05/2025 02:11:55.306 7f578b3a9cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 05/05/2025 02:11:55.306 7f578b3a9cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 05/05/2025 02:11:55.306 7f578b3a9cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 05/05/2025 02:11:55.306 7f578b3a9cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:55.306 7f578b3a9cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=286255758, session_epoch=448, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.306 7f578b3a9cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 451 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=286255758, session_epoch=448, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.307 7f578b3a9cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61135.054932, idle connection 378.000000, request 304999.962330 05/05/2025 02:11:55.307 7f578b3e1828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62075.712158, idle connection 395.000000, request 304396.478176 05/05/2025 02:11:55.307 7f5796863cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61107.594482, idle connection 337.000000, request 304998.641014 05/05/2025 02:11:55.307 7f578b3e1828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 456 05/05/2025 02:11:55.307 7f578b3e1828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:55.308 7f578b3e1828 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 456 (604.266881942749 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1889094295, topics=[]) 05/05/2025 02:11:55.308 7f578b3e1828 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1889094295 with 0 response partitions (1 implied) 05/05/2025 02:11:55.308 7f578ae92d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 33 05/05/2025 02:11:55.308 7f578ae92d68 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 05/05/2025 02:11:55.308 7f578ae92d68 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 05/05/2025 02:11:55.308 7f578ae92d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:55.308 7f578ae92d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=390896471, session_epoch=455, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.308 7f578ae92d68 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 458 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=390896471, session_epoch=455, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.308 7f578ae92d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62268.616699, idle connection 723.000000, request 304999.964237 05/05/2025 02:11:55.309 7f578b3a9cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61132.937012, idle connection 376.000000, request 304997.848511 05/05/2025 02:11:55.309 7f578ae92d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62267.959717, idle connection 722.000000, request 304999.310017 05/05/2025 02:11:55.314 7f578b28c240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 76 05/05/2025 02:11:55.314 7f578b28c240 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 05/05/2025 02:11:55.315 7f578b28c240 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 05/05/2025 02:11:55.315 7f578b28c240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:55.315 7f578b28c240 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1799898802, session_epoch=464, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.315 7f578b28c240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 467 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1799898802, session_epoch=464, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.315 7f578b28c240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62351.342529, idle connection 549.000000, request 304999.961853 05/05/2025 02:11:55.315 7f578b28c240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62351.010254, idle connection 549.000000, request 304999.633551 05/05/2025 02:11:55.381 7f578afe4828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 68 05/05/2025 02:11:55.381 7f578afe4828 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 05/05/2025 02:11:55.381 7f578afe4828 [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)]) 05/05/2025 02:11:55.381 7f578afe4828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:55.381 7f578afe4828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1087803404, session_epoch=462, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.382 7f578afe4828 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 465 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1087803404, session_epoch=462, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.382 7f578afe4828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61638.498291, idle connection 607.000000, request 304999.945164 05/05/2025 02:11:55.382 7f578b43e0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 40 05/05/2025 02:11:55.382 7f578b43e0f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 05/05/2025 02:11:55.382 7f578b43e0f0 [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)]) 05/05/2025 02:11:55.382 7f578b43e0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:55.382 7f578b43e0f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2034123924, session_epoch=456, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.382 7f578b43e0f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 459 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2034123924, session_epoch=456, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.383 7f578b43e0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61468.995605, idle connection 545.000000, request 304999.961853 05/05/2025 02:11:55.383 7f578afe4828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61637.383789, idle connection 606.000000, request 304998.841524 05/05/2025 02:11:55.383 7f578b43e0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61468.304688, idle connection 544.000000, request 304999.275923 05/05/2025 02:11:55.427 7f578af15f60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61715.694336, idle connection 529.000000, request 304398.898602 05/05/2025 02:11:55.427 7f578af15f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 497 05/05/2025 02:11:55.427 7f578af15f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:55.428 7f578af15f60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 497 (601.8126010894775 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=546626154, topics=[]) 05/05/2025 02:11:55.428 7f578af15f60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 546626154 with 0 response partitions (1 implied) 05/05/2025 02:11:55.435 7f578b476d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60976.086914, idle connection 309.000000, request 304399.154425 05/05/2025 02:11:55.436 7f578b476d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 457 05/05/2025 02:11:55.436 7f578b476d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:55.436 7f578b476d68 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 457 (601.4297008514404 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1394807976, topics=[]) 05/05/2025 02:11:55.436 7f578b476d68 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1394807976 with 0 response partitions (1 implied) 05/05/2025 02:11:55.475 7f578b3eb978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 21 05/05/2025 02:11:55.475 7f578b3eb978 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 05/05/2025 02:11:55.475 7f578b3eb978 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 05/05/2025 02:11:55.476 7f578b3eb978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:55.476 7f578b3eb978 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=892475593, session_epoch=455, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.476 7f578b3eb978 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 458 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=892475593, session_epoch=455, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.476 7f578b3eb978 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61497.267578, idle connection 244.000000, request 304999.948740 05/05/2025 02:11:55.476 7f578b3eb978 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61496.819092, idle connection 244.000000, request 304999.508858 05/05/2025 02:11:55.481 7f578b4bbc18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 45 05/05/2025 02:11:55.481 7f578b4bbc18 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 05/05/2025 02:11:55.481 7f578b4bbc18 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 05/05/2025 02:11:55.481 7f578b4bbc18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:55.481 7f578b4bbc18 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1438358457, session_epoch=460, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.481 7f578b4bbc18 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 463 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1438358457, session_epoch=460, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.481 7f578b4bbc18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61975.631836, idle connection 369.000000, request 304999.960423 05/05/2025 02:11:55.482 7f578b4bbc18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61975.297852, idle connection 369.000000, request 304999.630213 05/05/2025 02:11:55.482 7f578b41e630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 17 05/05/2025 02:11:55.482 7f578b41e630 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 05/05/2025 02:11:55.482 7f578b41e630 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)]) 05/05/2025 02:11:55.482 7f578b41e630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:55.482 7f578b41e630 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=349838626, session_epoch=454, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.482 7f578b41e630 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 457 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=349838626, session_epoch=454, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.482 7f578b41e630 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61925.627197, idle connection 300.000000, request 304999.964714 05/05/2025 02:11:55.483 7f578b41e630 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61925.237305, idle connection 299.000000, request 304999.573231 05/05/2025 02:11:55.488 7f578b42d438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61757.108887, idle connection 338.000000, request 304396.965504 05/05/2025 02:11:55.489 7f578b42d438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 456 05/05/2025 02:11:55.489 7f578b42d438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:55.489 7f578b42d438 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 456 (603.4495830535889 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=170483227, topics=[]) 05/05/2025 02:11:55.489 7f578b42d438 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 170483227 with 0 response partitions (1 implied) 05/05/2025 02:11:55.489 7f578b46f048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61971.341553, idle connection 322.000000, request 304396.875620 05/05/2025 02:11:55.489 7f578b41d588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62081.030029, idle connection 453.000000, request 304397.744894 05/05/2025 02:11:55.489 7f578b46f048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 456 05/05/2025 02:11:55.489 7f578b46f048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:55.490 7f578b46f048 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 456 (603.5921573638916 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=270212331, topics=[]) 05/05/2025 02:11:55.490 7f578b46f048 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 270212331 with 0 response partitions (1 implied) 05/05/2025 02:11:55.490 7f578b41d588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 487 05/05/2025 02:11:55.490 7f578b41d588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:55.490 7f578b41d588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 487 (603.0387878417969 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1679627920, topics=[]) 05/05/2025 02:11:55.490 7f578b41d588 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1679627920 with 0 response partitions (1 implied) 05/05/2025 02:11:55.490 7f578b444d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61641.338623, idle connection 572.000000, request 304397.272587 05/05/2025 02:11:55.491 7f578b444d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 475 05/05/2025 02:11:55.491 7f578b444d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:55.491 7f578b444d68 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 475 (603.0368804931641 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1801466066, topics=[]) 05/05/2025 02:11:55.491 7f578b444d68 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1801466066 with 0 response partitions (1 implied) 05/05/2025 02:11:55.530 7f578b4a0e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2366 05/05/2025 02:11:55.530 7f578b4a0e10 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 05/05/2025 02:11:55.530 7f578b4a0e10 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 05/05/2025 02:11:55.530 7f578b4a0e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:55.530 7f578b4a0e10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2017973102, session_epoch=670, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.530 7f578b4a0e10 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 673 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2017973102, session_epoch=670, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.531 7f578b4a0e10 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61044.206055, idle connection 110.000000, request 304999.946117 05/05/2025 02:11:55.531 7f578b4a0e10 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61043.770752, idle connection 110.000000, request 304999.520302 05/05/2025 02:11:55.587 7f578b4c7438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62070.982178, idle connection 248.000000, request 304399.008274 05/05/2025 02:11:55.587 7f578b4c7438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 461 05/05/2025 02:11:55.587 7f578b4c7438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:55.587 7f578b4c7438 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 461 (601.5236377716064 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1278798477, topics=[]) 05/05/2025 02:11:55.587 7f578b4c7438 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1278798477 with 0 response partitions (1 implied) 05/05/2025 02:11:55.602 7f578b4bb048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61279.381348, idle connection 130.000000, request 304399.167776 05/05/2025 02:11:55.603 7f578b4bb048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 455 05/05/2025 02:11:55.603 7f578b4bb048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:55.603 7f578b4bb048 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 455 (601.287841796875 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=182402792, topics=[]) 05/05/2025 02:11:55.603 7f578b4bb048 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 182402792 with 0 response partitions (1 implied) 05/05/2025 02:11:55.609 7f578b25a588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 62241.116699, idle connection 489.000000, request 304398.962021 05/05/2025 02:11:55.609 7f578b25a588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 479 05/05/2025 02:11:55.609 7f578b25a588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:55.610 7f578b25a588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 479 (601.4552116394043 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1554889754, topics=[]) 05/05/2025 02:11:55.610 7f578b25a588 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1554889754 with 0 response partitions (1 implied) 05/05/2025 02:11:55.634 7f578aefbcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 163 05/05/2025 02:11:55.634 7f578aefbcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 05/05/2025 02:11:55.634 7f578aefbcc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 05/05/2025 02:11:55.634 7f578aefbcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:55.634 7f578aefbcc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=277208274, session_epoch=475, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.634 7f578aefbcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 478 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=277208274, session_epoch=475, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.635 7f578aefbcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61317.047119, idle connection 436.000000, request 304999.947071 05/05/2025 02:11:55.635 7f578b4a1828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61652.662598, idle connection 275.000000, request 304397.653580 05/05/2025 02:11:55.635 7f578aefbcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61316.453613, idle connection 435.000000, request 304999.362707 05/05/2025 02:11:55.635 7f578b4a1828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 455 05/05/2025 02:11:55.635 7f578b4a1828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:55.636 7f578b4a1828 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 455 (603.065013885498 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=287674646, topics=[]) 05/05/2025 02:11:55.636 7f578b4a1828 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 287674646 with 0 response partitions (1 implied) 05/05/2025 02:11:55.651 7f578aea1198 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61339.364014, idle connection 307.000000, request 304399.203300 05/05/2025 02:11:55.652 7f578aea1198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 485 05/05/2025 02:11:55.652 7f578aea1198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:55.652 7f578aea1198 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 485 (601.3641357421875 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1832307886, topics=[]) 05/05/2025 02:11:55.652 7f578aea1198 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1832307886 with 0 response partitions (1 implied) 05/05/2025 02:11:55.656 7f578b3c8d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 12 05/05/2025 02:11:55.656 7f578b3c8d68 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 05/05/2025 02:11:55.656 7f578b3c8d68 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 05/05/2025 02:11:55.656 7f578b3c8d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:55.657 7f578b3c8d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1877425480, session_epoch=452, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.657 7f578b3c8d68 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 455 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1877425480, session_epoch=452, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.657 7f578b3c8d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61149.601074, idle connection 104.000000, request 304999.956131 05/05/2025 02:11:55.657 7f578b3c8d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61149.206299, idle connection 104.000000, request 304999.566555 05/05/2025 02:11:55.709 7f578b4a50f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60818.023193, idle connection 0.000000, request 304398.938656 05/05/2025 02:11:55.710 7f578b4a50f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 477 05/05/2025 02:11:55.710 7f578b4a50f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:55.710 7f578b4a50f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 477 (601.5985012054443 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1369124269, topics=[]) 05/05/2025 02:11:55.710 7f578b4a50f0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1369124269 with 0 response partitions (1 implied) 05/05/2025 02:11:55.747 7f578b7a42e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61564.906982, idle connection 0.000000, request 304399.012804 05/05/2025 02:11:55.747 7f578b7a42e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 455 05/05/2025 02:11:55.747 7f578b7a42e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:55.748 7f578b7a42e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 455 (601.7448902130127 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1754878510, topics=[]) 05/05/2025 02:11:55.748 7f578b7a42e8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1754878510 with 0 response partitions (1 implied) 05/05/2025 02:11:55.761 7f578afd6390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60819.002441, idle connection 130.000000, request 304399.042845 05/05/2025 02:11:55.762 7f578afd6390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 456 05/05/2025 02:11:55.762 7f578afd6390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:55.762 7f578afd6390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 456 (601.5157699584961 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1604738415, topics=[]) 05/05/2025 02:11:55.762 7f578afd6390 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1604738415 with 0 response partitions (1 implied) 05/05/2025 02:11:55.766 7f578b42d2e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 4 05/05/2025 02:11:55.766 7f578b42d2e8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 05/05/2025 02:11:55.766 7f578b42d2e8 [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)]) 05/05/2025 02:11:55.766 7f578b42d2e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:55.766 7f578b42d2e8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=739843525, session_epoch=450, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.767 7f578b42d2e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 453 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=739843525, session_epoch=450, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.767 7f578b42d2e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61041.716797, idle connection 27.000000, request 304999.952555 05/05/2025 02:11:55.767 7f578adb42e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 225 05/05/2025 02:11:55.767 7f578adb42e8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 05/05/2025 02:11:55.767 7f578adb42e8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 05/05/2025 02:11:55.767 7f578adb42e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:55.767 7f578adb42e8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1209576856, session_epoch=481, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.767 7f578adb42e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 484 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1209576856, session_epoch=481, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.767 7f578adb42e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61784.895996, idle connection 352.000000, request 304999.960423 05/05/2025 02:11:55.768 7f578b42d2e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61040.582520, idle connection 26.000000, request 304998.819590 05/05/2025 02:11:55.768 7f578adb42e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61784.064209, idle connection 352.000000, request 304999.128819 05/05/2025 02:11:55.874 7f578b3d26d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 90 05/05/2025 02:11:55.874 7f578b3d26d8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 05/05/2025 02:11:55.874 7f578b3d26d8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 05/05/2025 02:11:55.874 7f578b3d26d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:55.875 7f578b3d26d8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=522221117, session_epoch=473, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.875 7f578b3d26d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 476 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=522221117, session_epoch=473, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.875 7f578b3d26d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61560.755859, idle connection 168.000000, request 304999.943972 05/05/2025 02:11:55.875 7f578b3d26d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61560.300537, idle connection 167.000000, request 304999.499321 05/05/2025 02:11:55.908 7f578b3e1828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 19 05/05/2025 02:11:55.908 7f578b3e1828 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 05/05/2025 02:11:55.908 7f578b3e1828 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 05/05/2025 02:11:55.908 7f578b3e1828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:55.908 7f578b3e1828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1889094295, session_epoch=454, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.909 7f578b3e1828 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 457 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1889094295, session_epoch=454, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:55.909 7f578b3e1828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61473.725586, idle connection 0.000000, request 304999.949932 05/05/2025 02:11:55.909 7f5796863cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60505.725830, idle connection 0.000000, request 304396.771669 05/05/2025 02:11:55.909 7f578b3e1828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61473.121582, idle connection 539397.000000, request 304999.353409 05/05/2025 02:11:55.910 7f5796863cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 451 05/05/2025 02:11:55.910 7f5796863cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:55.910 7f5796863cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 451 (603.9755344390869 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1265972283, topics=[]) 05/05/2025 02:11:55.910 7f5796863cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1265972283 with 0 response partitions (1 implied) 05/05/2025 02:11:55.910 7f578b3a9cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60531.490234, idle connection 0.000000, request 304396.388054 05/05/2025 02:11:55.910 7f578ae92d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61666.719482, idle connection 121.000000, request 304398.068190 05/05/2025 02:11:55.911 7f578b3a9cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 451 05/05/2025 02:11:55.911 7f578b3a9cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:55.911 7f578b3a9cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 451 (604.1488647460938 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=286255758, topics=[]) 05/05/2025 02:11:55.911 7f578b3a9cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 286255758 with 0 response partitions (1 implied) 05/05/2025 02:11:55.911 7f578ae92d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 458 05/05/2025 02:11:55.911 7f578ae92d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:55.911 7f578ae92d68 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 458 (602.820634841919 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=390896471, topics=[]) 05/05/2025 02:11:55.911 7f578ae92d68 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 390896471 with 0 response partitions (1 implied) 05/05/2025 02:11:55.916 7f578b28c240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61750.672852, idle connection 0.000000, request 304399.292231 05/05/2025 02:11:55.916 7f578b28c240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 467 05/05/2025 02:11:55.916 7f578b28c240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:55.916 7f578b28c240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 467 (601.0720729827881 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1799898802, topics=[]) 05/05/2025 02:11:55.916 7f578b28c240 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1799898802 with 0 response partitions (1 implied) 05/05/2025 02:11:55.984 7f578afe4828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61036.674805, idle connection 5.000000, request 304398.121119 05/05/2025 02:11:55.984 7f578afe4828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 465 05/05/2025 02:11:55.984 7f578afe4828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:55.984 7f578afe4828 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 465 (602.4186611175537 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1087803404, topics=[]) 05/05/2025 02:11:55.984 7f578afe4828 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1087803404 with 0 response partitions (1 implied) 05/05/2025 02:11:55.985 7f578b43e0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60866.972168, idle connection 0.000000, request 304397.940636 05/05/2025 02:11:55.985 7f578b43e0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 459 05/05/2025 02:11:55.985 7f578b43e0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:55.985 7f578b43e0f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 459 (602.3705005645752 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2034123924, topics=[]) 05/05/2025 02:11:55.985 7f578b43e0f0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2034123924 with 0 response partitions (1 implied) 05/05/2025 02:11:56.028 7f578af15f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 219 05/05/2025 02:11:56.028 7f578af15f60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 05/05/2025 02:11:56.028 7f578af15f60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 05/05/2025 02:11:56.029 7f578af15f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:56.029 7f578af15f60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=546626154, session_epoch=495, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.029 7f578af15f60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 498 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=546626154, session_epoch=495, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.029 7f578af15f60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61113.548828, idle connection 0.000000, request 304999.946594 05/05/2025 02:11:56.029 7f578af15f60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61113.083740, idle connection 539397.000000, request 304999.490023 05/05/2025 02:11:56.037 7f578b476d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 17 05/05/2025 02:11:56.037 7f578b476d68 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 05/05/2025 02:11:56.037 7f578b476d68 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 05/05/2025 02:11:56.037 7f578b476d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:56.037 7f578b476d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1394807976, session_epoch=455, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.037 7f578b476d68 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 458 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1394807976, session_epoch=455, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.037 7f578b476d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60374.305664, idle connection 0.000000, request 304999.957323 05/05/2025 02:11:56.038 7f578b476d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60373.940186, idle connection 539398.000000, request 304999.594927 05/05/2025 02:11:56.077 7f578b3eb978 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60896.310059, idle connection 0.000000, request 304398.992538 05/05/2025 02:11:56.077 7f578b3eb978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 458 05/05/2025 02:11:56.077 7f578b3eb978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:56.077 7f578b3eb978 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 458 (601.5093326568604 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=892475593, topics=[]) 05/05/2025 02:11:56.078 7f578b3eb978 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 892475593 with 0 response partitions (1 implied) 05/05/2025 02:11:56.083 7f578b4bbc18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61374.266602, idle connection 0.000000, request 304398.592949 05/05/2025 02:11:56.083 7f578b4bbc18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 463 05/05/2025 02:11:56.083 7f578b4bbc18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:56.083 7f578b4bbc18 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 463 (601.8216609954834 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1438358457, topics=[]) 05/05/2025 02:11:56.083 7f578b4bbc18 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1438358457 with 0 response partitions (1 implied) 05/05/2025 02:11:56.084 7f578b41e630 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61324.463379, idle connection 0.000000, request 304398.800373 05/05/2025 02:11:56.084 7f578b41e630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 457 05/05/2025 02:11:56.084 7f578b41e630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:56.084 7f578b41e630 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 457 (601.550817489624 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=349838626, topics=[]) 05/05/2025 02:11:56.084 7f578b41e630 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 349838626 with 0 response partitions (1 implied) 05/05/2025 02:11:56.089 7f578b42d438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 28 05/05/2025 02:11:56.089 7f578b42d438 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 05/05/2025 02:11:56.089 7f578b42d438 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 05/05/2025 02:11:56.089 7f578b42d438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:56.089 7f578b42d438 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=170483227, session_epoch=454, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.090 7f578b42d438 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 457 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=170483227, session_epoch=454, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.090 7f578b42d438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61155.705811, idle connection 0.000000, request 304999.957800 05/05/2025 02:11:56.090 7f578b46f048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 23 05/05/2025 02:11:56.090 7f578b46f048 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 05/05/2025 02:11:56.090 7f578b46f048 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 05/05/2025 02:11:56.090 7f578b46f048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:56.090 7f578b46f048 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=270212331, session_epoch=454, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.090 7f578b46f048 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 457 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=270212331, session_epoch=454, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.090 7f578b46f048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61370.026611, idle connection 0.000000, request 304999.964952 05/05/2025 02:11:56.091 7f578b42d438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61154.659668, idle connection 539397.000000, request 304998.914719 05/05/2025 02:11:56.091 7f578b41d588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 247 05/05/2025 02:11:56.091 7f578b41d588 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 05/05/2025 02:11:56.091 7f578b41d588 [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)]) 05/05/2025 02:11:56.091 7f578b41d588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:56.091 7f578b41d588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1679627920, session_epoch=485, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.091 7f578b41d588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 488 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1679627920, session_epoch=485, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.091 7f578b41d588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61478.768555, idle connection 0.000000, request 304999.961138 05/05/2025 02:11:56.092 7f578b46f048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61368.600342, idle connection 539397.000000, request 304998.541117 05/05/2025 02:11:56.092 7f578b444d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 174 05/05/2025 02:11:56.092 7f578b444d68 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 05/05/2025 02:11:56.092 7f578b444d68 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 05/05/2025 02:11:56.092 7f578b444d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:56.092 7f578b444d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1801466066, session_epoch=473, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.092 7f578b444d68 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 476 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1801466066, session_epoch=473, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.093 7f578b444d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61039.119629, idle connection 0.000000, request 304999.964237 05/05/2025 02:11:56.093 7f578b41d588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61477.400146, idle connection 539396.000000, request 304998.596430 05/05/2025 02:11:56.093 7f578b444d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61038.451660, idle connection 539397.000000, request 304999.299288 05/05/2025 02:11:56.132 7f578b4a0e10 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60443.301025, idle connection 0.000000, request 304399.040461 05/05/2025 02:11:56.132 7f578b4a0e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 673 05/05/2025 02:11:56.132 7f578b4a0e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:56.132 7f578b4a0e10 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 673 (601.5677452087402 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2017973102, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=2367, last_stable_offset=2367, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\t>\x00\x00\x01\x04\x00\x00\x00\x00\x02\xb7\x05\xb0\xd0\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xa2\x03\x00\x00\x00\xe4\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 05/05/2025 02:11:56.132 7f578b4a0e10 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2017973102 with 1 response partitions (0 implied) 05/05/2025 02:11:56.133 7f578b4a0e10 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 272 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 2366 05/05/2025 02:11:56.133 7f578b4a0e10 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 2366 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 05/05/2025 02:11:56.133 7f578b4a0e10 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 2367 (leader epoch 0) 05/05/2025 02:11:56.188 7f578b4c7438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 47 05/05/2025 02:11:56.188 7f578b4c7438 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 05/05/2025 02:11:56.188 7f578b4c7438 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)]) 05/05/2025 02:11:56.188 7f578b4c7438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:56.188 7f578b4c7438 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1278798477, session_epoch=459, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.188 7f578b4c7438 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 462 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1278798477, session_epoch=459, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.188 7f578b4c7438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61469.161133, idle connection 0.000000, request 304999.946356 05/05/2025 02:11:56.189 7f578b4c7438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61468.727783, idle connection 539398.000000, request 304999.521971 05/05/2025 02:11:56.203 7f578b4bb048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 14 05/05/2025 02:11:56.204 7f578b4bb048 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 05/05/2025 02:11:56.204 7f578b4bb048 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 05/05/2025 02:11:56.204 7f578b4bb048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:56.204 7f578b4bb048 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=182402792, session_epoch=453, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.204 7f578b4bb048 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 456 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=182402792, session_epoch=453, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.204 7f578b4bb048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60677.240723, idle connection 0.000000, request 304999.923944 05/05/2025 02:11:56.205 7f578b4bb048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60676.629883, idle connection 539397.000000, request 304999.321699 05/05/2025 02:11:56.210 7f578b25a588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 194 05/05/2025 02:11:56.211 7f578b25a588 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 05/05/2025 02:11:56.211 7f578b25a588 [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)]) 05/05/2025 02:11:56.211 7f578b25a588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:56.211 7f578b25a588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1554889754, session_epoch=477, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.211 7f578b25a588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 480 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1554889754, session_epoch=477, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.211 7f578b25a588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61639.188232, idle connection 0.000000, request 304999.945641 05/05/2025 02:11:56.211 7f578b25a588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61638.807617, idle connection 539397.000000, request 304999.581337 05/05/2025 02:11:56.233 7f578b4a0e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2367 05/05/2025 02:11:56.233 7f578b4a0e10 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 05/05/2025 02:11:56.233 7f578b4a0e10 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-0', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 05/05/2025 02:11:56.234 7f578b4a0e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:56.234 7f578b4a0e10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2017973102, session_epoch=671, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=2367, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 05/05/2025 02:11:56.234 7f578b4a0e10 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 674 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2017973102, session_epoch=671, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=2367, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 05/05/2025 02:11:56.234 7f578b4a0e10 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60340.844482, idle connection 539897.000000, request 304999.952316 05/05/2025 02:11:56.234 7f578b4a0e10 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60340.442871, idle connection 539897.000000, request 304999.556541 05/05/2025 02:11:56.236 7f578b4a1828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 23 05/05/2025 02:11:56.236 7f578b4a1828 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 05/05/2025 02:11:56.236 7f578b4a1828 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)]) 05/05/2025 02:11:56.236 7f578b4a1828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:56.236 7f578b4a1828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=287674646, session_epoch=453, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.237 7f578b4a1828 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 456 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=287674646, session_epoch=453, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.237 7f578b4a1828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61050.870605, idle connection 0.000000, request 304999.963999 05/05/2025 02:11:56.237 7f578aefbcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60714.821533, idle connection 0.000000, request 304397.727966 05/05/2025 02:11:56.237 7f578b4a1828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61050.350098, idle connection 539398.000000, request 304999.445677 05/05/2025 02:11:56.237 7f578aefbcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 478 05/05/2025 02:11:56.237 7f578aefbcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:56.238 7f578aefbcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 478 (602.9922962188721 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=277208274, topics=[]) 05/05/2025 02:11:56.238 7f578aefbcc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 277208274 with 0 response partitions (1 implied) 05/05/2025 02:11:56.252 7f578aea1198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 137 05/05/2025 02:11:56.253 7f578aea1198 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 05/05/2025 02:11:56.253 7f578aea1198 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)]) 05/05/2025 02:11:56.253 7f578aea1198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:56.253 7f578aea1198 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1832307886, session_epoch=483, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.253 7f578aea1198 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 486 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1832307886, session_epoch=483, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.253 7f578aea1198 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60737.636230, idle connection 0.000000, request 304999.959469 05/05/2025 02:11:56.253 7f578aea1198 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60737.285400, idle connection 539398.000000, request 304999.613047 05/05/2025 02:11:56.258 7f578b3c8d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60548.802734, idle connection 0.000000, request 304399.158716 05/05/2025 02:11:56.258 7f578b3c8d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 455 05/05/2025 02:11:56.258 7f578b3c8d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:56.258 7f578b3c8d68 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 455 (601.262092590332 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1877425480, topics=[]) 05/05/2025 02:11:56.258 7f578b3c8d68 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1877425480 with 0 response partitions (1 implied) 05/05/2025 02:11:56.311 7f578b4a50f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 129 05/05/2025 02:11:56.311 7f578b4a50f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 05/05/2025 02:11:56.311 7f578b4a50f0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 05/05/2025 02:11:56.311 7f578b4a50f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:56.311 7f578b4a50f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1369124269, session_epoch=475, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.311 7f578b4a50f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 478 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1369124269, session_epoch=475, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.311 7f578b4a50f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60216.171875, idle connection 539398.000000, request 304999.937296 05/05/2025 02:11:56.312 7f578b4a50f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60215.714844, idle connection 539397.000000, request 304999.487638 05/05/2025 02:11:56.348 7f578b7a42e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 16 05/05/2025 02:11:56.348 7f578b7a42e8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 05/05/2025 02:11:56.348 7f578b7a42e8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 05/05/2025 02:11:56.349 7f578b7a42e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:56.349 7f578b7a42e8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1754878510, session_epoch=453, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.349 7f578b7a42e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 456 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1754878510, session_epoch=453, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.349 7f578b7a42e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60962.680176, idle connection 539398.000000, request 304999.945164 05/05/2025 02:11:56.349 7f578b7a42e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60962.242188, idle connection 539397.000000, request 304999.517441 05/05/2025 02:11:56.363 7f578afd6390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 21 05/05/2025 02:11:56.363 7f578afd6390 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 05/05/2025 02:11:56.363 7f578afd6390 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 05/05/2025 02:11:56.363 7f578afd6390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:56.363 7f578afd6390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1604738415, session_epoch=454, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.363 7f578afd6390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 457 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1604738415, session_epoch=454, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.363 7f578afd6390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60217.140381, idle connection 0.000000, request 304999.952078 05/05/2025 02:11:56.364 7f578afd6390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60216.766113, idle connection 539397.000000, request 304999.583006 05/05/2025 02:11:56.369 7f578b42d2e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60439.730957, idle connection 0.000000, request 304397.971869 05/05/2025 02:11:56.369 7f578b42d2e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 453 05/05/2025 02:11:56.369 7f578b42d2e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:56.369 7f578b42d2e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 453 (602.4150848388672 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=739843525, topics=[]) 05/05/2025 02:11:56.369 7f578b42d2e8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 739843525 with 0 response partitions (1 implied) 05/05/2025 02:11:56.369 7f578adb42e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61182.902100, idle connection 0.000000, request 304397.969484 05/05/2025 02:11:56.370 7f578adb42e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 484 05/05/2025 02:11:56.370 7f578adb42e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:56.370 7f578adb42e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 484 (602.3478507995605 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1209576856, topics=[]) 05/05/2025 02:11:56.370 7f578adb42e8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1209576856 with 0 response partitions (1 implied) 05/05/2025 02:11:56.476 7f578b3d26d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60959.806396, idle connection 0.000000, request 304398.996592 05/05/2025 02:11:56.476 7f578b3d26d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 476 05/05/2025 02:11:56.476 7f578b3d26d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:56.476 7f578b3d26d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 476 (601.5582084655762 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=522221117, topics=[]) 05/05/2025 02:11:56.477 7f578b3d26d8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 522221117 with 0 response partitions (1 implied) 05/05/2025 02:11:56.510 7f5796863cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 05/05/2025 02:11:56.510 7f5796863cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 05/05/2025 02:11:56.510 7f5796863cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)]) 05/05/2025 02:11:56.511 7f5796863cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:56.511 7f5796863cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1265972283, session_epoch=449, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.511 7f5796863cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 452 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1265972283, session_epoch=449, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.511 7f5796863cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59903.721191, idle connection 539398.000000, request 304999.947309 05/05/2025 02:11:56.511 7f578b3e1828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60871.206787, idle connection 538796.000000, request 304397.436619 05/05/2025 02:11:56.511 7f578b3a9cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 05/05/2025 02:11:56.511 7f578b3a9cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 05/05/2025 02:11:56.511 7f578b3a9cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 05/05/2025 02:11:56.512 7f578b3a9cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:56.512 7f578b3a9cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=286255758, session_epoch=449, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.512 7f578b3a9cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 452 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=286255758, session_epoch=449, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.512 7f578b3a9cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59929.688232, idle connection 539398.000000, request 304999.963284 05/05/2025 02:11:56.512 7f5796863cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59902.361816, idle connection 539397.000000, request 304998.597145 05/05/2025 02:11:56.513 7f578b3e1828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 457 05/05/2025 02:11:56.513 7f578b3e1828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:56.513 7f578b3e1828 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 457 (604.0680408477783 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1889094295, topics=[]) 05/05/2025 02:11:56.513 7f578b3e1828 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1889094295 with 0 response partitions (1 implied) 05/05/2025 02:11:56.513 7f578ae92d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 33 05/05/2025 02:11:56.513 7f578ae92d68 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 05/05/2025 02:11:56.513 7f578ae92d68 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 05/05/2025 02:11:56.513 7f578ae92d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:56.513 7f578ae92d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=390896471, session_epoch=456, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.513 7f578ae92d68 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 459 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=390896471, session_epoch=456, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.514 7f578ae92d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61063.348877, idle connection 0.000000, request 304999.962807 05/05/2025 02:11:56.514 7f578b3a9cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59927.658691, idle connection 539396.000000, request 304997.937441 05/05/2025 02:11:56.514 7f578ae92d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61062.602295, idle connection 539396.000000, request 304999.219418 05/05/2025 02:11:56.517 7f578b28c240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 76 05/05/2025 02:11:56.517 7f578b28c240 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 05/05/2025 02:11:56.517 7f578b28c240 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 05/05/2025 02:11:56.517 7f578b28c240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:56.517 7f578b28c240 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1799898802, session_epoch=465, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.517 7f578b28c240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 468 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1799898802, session_epoch=465, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.517 7f578b28c240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61148.884033, idle connection 539398.000000, request 304999.961853 05/05/2025 02:11:56.518 7f578b28c240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61148.474121, idle connection 539397.000000, request 304999.551296 05/05/2025 02:11:56.585 7f578afe4828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 68 05/05/2025 02:11:56.585 7f578afe4828 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 05/05/2025 02:11:56.585 7f578afe4828 [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)]) 05/05/2025 02:11:56.585 7f578afe4828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:56.585 7f578afe4828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1087803404, session_epoch=463, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.585 7f578afe4828 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 466 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1087803404, session_epoch=463, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.585 7f578afe4828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60434.912354, idle connection 0.000000, request 304999.945641 05/05/2025 02:11:56.586 7f578b43e0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 40 05/05/2025 02:11:56.586 7f578b43e0f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 05/05/2025 02:11:56.586 7f578b43e0f0 [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)]) 05/05/2025 02:11:56.586 7f578b43e0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:56.586 7f578b43e0f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2034123924, session_epoch=457, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.586 7f578b43e0f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 460 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2034123924, session_epoch=457, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.586 7f578b43e0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60265.421387, idle connection 539398.000000, request 304999.963284 05/05/2025 02:11:56.586 7f578afe4828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60433.816895, idle connection 539397.000000, request 304998.861313 05/05/2025 02:11:56.587 7f578b43e0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60264.749756, idle connection 539397.000000, request 304999.296427 05/05/2025 02:11:56.630 7f578af15f60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60512.608643, idle connection 538797.000000, request 304399.009705 05/05/2025 02:11:56.630 7f578af15f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 498 05/05/2025 02:11:56.630 7f578af15f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:56.630 7f578af15f60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 498 (601.4883518218994 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=546626154, topics=[]) 05/05/2025 02:11:56.631 7f578af15f60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 546626154 with 0 response partitions (1 implied) 05/05/2025 02:11:56.638 7f578b476d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59773.582275, idle connection 538797.000000, request 304399.232149 05/05/2025 02:11:56.638 7f578b476d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 458 05/05/2025 02:11:56.638 7f578b476d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:56.638 7f578b476d68 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 458 (601.1238098144531 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1394807976, topics=[]) 05/05/2025 02:11:56.638 7f578b476d68 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1394807976 with 0 response partitions (1 implied) 05/05/2025 02:11:56.678 7f578b3eb978 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 21 05/05/2025 02:11:56.678 7f578b3eb978 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 05/05/2025 02:11:56.678 7f578b3eb978 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-6', partition=0)]) 05/05/2025 02:11:56.678 7f578b3eb978 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:56.678 7f578b3eb978 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=892475593, session_epoch=456, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.678 7f578b3eb978 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 459 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=892475593, session_epoch=456, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.678 7f578b3eb978 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60294.737305, idle connection 539398.000000, request 304999.953270 05/05/2025 02:11:56.679 7f578b3eb978 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60294.331787, idle connection 539398.000000, request 304999.554396 05/05/2025 02:11:56.684 7f578b4bbc18 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 45 05/05/2025 02:11:56.684 7f578b4bbc18 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 05/05/2025 02:11:56.684 7f578b4bbc18 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)]) 05/05/2025 02:11:56.684 7f578b4bbc18 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:56.684 7f578b4bbc18 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1438358457, session_epoch=461, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.684 7f578b4bbc18 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 464 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1438358457, session_epoch=461, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.684 7f578b4bbc18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60772.866211, idle connection 539398.000000, request 304999.950409 05/05/2025 02:11:56.684 7f578b41e630 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 17 05/05/2025 02:11:56.684 7f578b41e630 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 05/05/2025 02:11:56.684 7f578b41e630 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)]) 05/05/2025 02:11:56.684 7f578b41e630 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:56.685 7f578b41e630 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=349838626, session_epoch=455, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.685 7f578b41e630 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 458 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=349838626, session_epoch=455, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.685 7f578b41e630 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60723.201172, idle connection 539398.000000, request 304999.966383 05/05/2025 02:11:56.685 7f578b4bbc18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60771.901367, idle connection 539397.000000, request 304998.989105 05/05/2025 02:11:56.685 7f578b41e630 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60722.592041, idle connection 539398.000000, request 304999.359846 05/05/2025 02:11:56.692 7f578b42d438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60553.281250, idle connection 538796.000000, request 304397.535086 05/05/2025 02:11:56.692 7f578b42d438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 457 05/05/2025 02:11:56.692 7f578b42d438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:56.693 7f578b42d438 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 457 (602.8425693511963 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=170483227, topics=[]) 05/05/2025 02:11:56.693 7f578b42d438 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 170483227 with 0 response partitions (1 implied) 05/05/2025 02:11:56.693 7f578b46f048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60767.273682, idle connection 538796.000000, request 304397.212267 05/05/2025 02:11:56.693 7f578b46f048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 457 05/05/2025 02:11:56.693 7f578b46f048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:56.693 7f578b46f048 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 457 (603.1060218811035 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=270212331, topics=[]) 05/05/2025 02:11:56.694 7f578b46f048 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 270212331 with 0 response partitions (1 implied) 05/05/2025 02:11:56.694 7f578b41d588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60876.479492, idle connection 538796.000000, request 304397.673130 05/05/2025 02:11:56.694 7f578b444d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60437.769287, idle connection 538796.000000, request 304398.615599 05/05/2025 02:11:56.694 7f578b41d588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 488 05/05/2025 02:11:56.694 7f578b41d588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:56.694 7f578b41d588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 488 (602.76198387146 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1679627920, topics=[]) 05/05/2025 02:11:56.694 7f578b41d588 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1679627920 with 0 response partitions (1 implied) 05/05/2025 02:11:56.695 7f578b444d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 476 05/05/2025 02:11:56.695 7f578b444d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:56.695 7f578b444d68 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 476 (602.1606922149658 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1801466066, topics=[]) 05/05/2025 02:11:56.695 7f578b444d68 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1801466066 with 0 response partitions (1 implied) 05/05/2025 02:11:56.789 7f578b4c7438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60868.194336, idle connection 538797.000000, request 304398.976326 05/05/2025 02:11:56.790 7f578b4c7438 [kafka.protocol.parser] [DEBUG]: Received correlation id: 462 05/05/2025 02:11:56.790 7f578b4c7438 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:56.790 7f578b4c7438 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 462 (601.5441417694092 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1278798477, topics=[]) 05/05/2025 02:11:56.790 7f578b4c7438 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1278798477 with 0 response partitions (1 implied) 05/05/2025 02:11:56.806 7f578b4bb048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60076.050049, idle connection 538796.000000, request 304398.738146 05/05/2025 02:11:56.806 7f578b4bb048 [kafka.protocol.parser] [DEBUG]: Received correlation id: 456 05/05/2025 02:11:56.806 7f578b4bb048 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:56.806 7f578b4bb048 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 456 (601.7298698425293 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=182402792, topics=[]) 05/05/2025 02:11:56.806 7f578b4bb048 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 182402792 with 0 response partitions (1 implied) 05/05/2025 02:11:56.812 7f578b25a588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 61038.246094, idle connection 538797.000000, request 304399.014950 05/05/2025 02:11:56.812 7f578b25a588 [kafka.protocol.parser] [DEBUG]: Received correlation id: 480 05/05/2025 02:11:56.812 7f578b25a588 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:56.812 7f578b25a588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 480 (601.355791091919 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1554889754, topics=[]) 05/05/2025 02:11:56.813 7f578b25a588 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1554889754 with 0 response partitions (1 implied) 05/05/2025 02:11:56.835 7f578b4a0e10 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59740.050049, idle connection 539297.000000, request 304399.158478 05/05/2025 02:11:56.835 7f578b4a0e10 [kafka.protocol.parser] [DEBUG]: Received correlation id: 674 05/05/2025 02:11:56.835 7f578b4a0e10 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:56.835 7f578b4a0e10 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 674 (601.2263298034668 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2017973102, topics=[]) 05/05/2025 02:11:56.835 7f578b4a0e10 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2017973102 with 0 response partitions (1 implied) 05/05/2025 02:11:56.838 7f578aefbcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 163 05/05/2025 02:11:56.838 7f578aefbcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 05/05/2025 02:11:56.838 7f578aefbcc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-27', partition=0)]) 05/05/2025 02:11:56.838 7f578aefbcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:56.838 7f578aefbcc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=277208274, session_epoch=476, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.838 7f578aefbcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 479 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=277208274, session_epoch=476, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.839 7f578aefbcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60113.153320, idle connection 539398.000000, request 304999.954700 05/05/2025 02:11:56.839 7f578b4a1828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60448.793213, idle connection 538796.000000, request 304397.886992 05/05/2025 02:11:56.839 7f578aefbcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60112.627930, idle connection 539398.000000, request 304999.435186 05/05/2025 02:11:56.839 7f578b4a1828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 456 05/05/2025 02:11:56.839 7f578b4a1828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:56.839 7f578b4a1828 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 456 (602.7729511260986 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=287674646, topics=[]) 05/05/2025 02:11:56.840 7f578b4a1828 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 287674646 with 0 response partitions (1 implied) 05/05/2025 02:11:56.854 7f578aea1198 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60136.933350, idle connection 538797.000000, request 304399.256229 05/05/2025 02:11:56.854 7f578aea1198 [kafka.protocol.parser] [DEBUG]: Received correlation id: 486 05/05/2025 02:11:56.854 7f578aea1198 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:56.854 7f578aea1198 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 486 (601.1314392089844 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1832307886, topics=[]) 05/05/2025 02:11:56.854 7f578aea1198 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1832307886 with 0 response partitions (1 implied) 05/05/2025 02:11:56.858 7f578b3c8d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 12 05/05/2025 02:11:56.858 7f578b3c8d68 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 05/05/2025 02:11:56.859 7f578b3c8d68 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-9', partition=0)]) 05/05/2025 02:11:56.859 7f578b3c8d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:56.859 7f578b3c8d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1877425480, session_epoch=453, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.859 7f578b3c8d68 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 456 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1877425480, session_epoch=453, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.859 7f578b3c8d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59947.418701, idle connection 539398.000000, request 304999.957085 05/05/2025 02:11:56.859 7f578b3c8d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59946.937012, idle connection 539398.000000, request 304999.479294 05/05/2025 02:11:56.912 7f578b4a50f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59615.182373, idle connection 538797.000000, request 304398.952961 05/05/2025 02:11:56.913 7f578b4a50f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 478 05/05/2025 02:11:56.913 7f578b4a50f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:56.913 7f578b4a50f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 478 (601.4728546142578 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1369124269, topics=[]) 05/05/2025 02:11:56.913 7f578b4a50f0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1369124269 with 0 response partitions (1 implied) 05/05/2025 02:11:56.950 7f578b7a42e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60361.789551, idle connection 538797.000000, request 304399.056673 05/05/2025 02:11:56.950 7f578b7a42e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 456 05/05/2025 02:11:56.950 7f578b7a42e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:56.950 7f578b7a42e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 456 (601.4459133148193 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1754878510, topics=[]) 05/05/2025 02:11:56.951 7f578b7a42e8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1754878510 with 0 response partitions (1 implied) 05/05/2025 02:11:56.964 7f578afd6390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59616.366943, idle connection 538797.000000, request 304399.177790 05/05/2025 02:11:56.964 7f578afd6390 [kafka.protocol.parser] [DEBUG]: Received correlation id: 457 05/05/2025 02:11:56.964 7f578afd6390 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:56.964 7f578afd6390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 457 (601.2425422668457 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1604738415, topics=[]) 05/05/2025 02:11:56.965 7f578afd6390 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1604738415 with 0 response partitions (1 implied) 05/05/2025 02:11:56.970 7f578b42d2e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 4 05/05/2025 02:11:56.970 7f578b42d2e8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 05/05/2025 02:11:56.970 7f578b42d2e8 [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)]) 05/05/2025 02:11:56.970 7f578b42d2e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:56.970 7f578b42d2e8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=739843525, session_epoch=451, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.970 7f578b42d2e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 454 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=739843525, session_epoch=451, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.971 7f578b42d2e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59837.816162, idle connection 539398.000000, request 304999.952078 05/05/2025 02:11:56.971 7f578adb42e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 225 05/05/2025 02:11:56.971 7f578adb42e8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 05/05/2025 02:11:56.971 7f578adb42e8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)]) 05/05/2025 02:11:56.971 7f578adb42e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:56.971 7f578adb42e8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1209576856, session_epoch=482, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.971 7f578adb42e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 485 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1209576856, session_epoch=482, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:56.971 7f578adb42e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60581.021240, idle connection 539398.000000, request 304999.962091 05/05/2025 02:11:56.972 7f578b42d2e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59836.744141, idle connection 539397.000000, request 304998.887300 05/05/2025 02:11:56.972 7f578adb42e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60580.230713, idle connection 539397.000000, request 304999.174833 05/05/2025 02:11:57.077 7f578b3d26d8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 90 05/05/2025 02:11:57.077 7f578b3d26d8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 05/05/2025 02:11:57.077 7f578b3d26d8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-25', partition=0)]) 05/05/2025 02:11:57.077 7f578b3d26d8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:57.077 7f578b3d26d8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=522221117, session_epoch=474, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.077 7f578b3d26d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 477 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=522221117, session_epoch=474, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.078 7f578b3d26d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60357.948975, idle connection 539398.000000, request 304999.946594 05/05/2025 02:11:57.078 7f578b3d26d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60357.372559, idle connection 539397.000000, request 304999.379158 05/05/2025 02:11:57.113 7f578b3e1828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 19 05/05/2025 02:11:57.113 7f578b3e1828 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 05/05/2025 02:11:57.113 7f578b3e1828 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)]) 05/05/2025 02:11:57.114 7f578b3e1828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:57.114 7f578b3e1828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1889094295, session_epoch=455, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.114 7f578b3e1828 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 458 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1889094295, session_epoch=455, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.114 7f578b3e1828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60268.593750, idle connection 538193.000000, request 304999.954224 05/05/2025 02:11:57.114 7f578b3e1828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60268.196045, idle connection 538192.000000, request 304999.562263 05/05/2025 02:11:57.114 7f5796863cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59300.256104, idle connection 538795.000000, request 304396.490574 05/05/2025 02:11:57.115 7f5796863cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 452 05/05/2025 02:11:57.115 7f5796863cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:57.115 7f5796863cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 452 (603.9516925811768 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1265972283, topics=[]) 05/05/2025 02:11:57.115 7f5796863cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1265972283 with 0 response partitions (1 implied) 05/05/2025 02:11:57.115 7f578b3a9cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59326.330811, idle connection 538795.000000, request 304396.607399 05/05/2025 02:11:57.115 7f578ae92d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60461.573486, idle connection 538795.000000, request 304398.189545 05/05/2025 02:11:57.116 7f578b3a9cc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 452 05/05/2025 02:11:57.116 7f578b3a9cc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:57.116 7f578b3a9cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 452 (603.839635848999 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=286255758, topics=[]) 05/05/2025 02:11:57.116 7f578b3a9cc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 286255758 with 0 response partitions (1 implied) 05/05/2025 02:11:57.116 7f578ae92d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 459 05/05/2025 02:11:57.116 7f578ae92d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:57.116 7f578ae92d68 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 459 (602.6351451873779 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=390896471, topics=[]) 05/05/2025 02:11:57.116 7f578ae92d68 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 390896471 with 0 response partitions (1 implied) 05/05/2025 02:11:57.118 7f578b28c240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60548.162354, idle connection 538797.000000, request 304399.234056 05/05/2025 02:11:57.118 7f578b28c240 [kafka.protocol.parser] [DEBUG]: Received correlation id: 468 05/05/2025 02:11:57.118 7f578b28c240 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:57.118 7f578b28c240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 468 (601.0646820068359 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1799898802, topics=[]) 05/05/2025 02:11:57.119 7f578b28c240 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1799898802 with 0 response partitions (1 implied) 05/05/2025 02:11:57.187 7f578afe4828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59833.146973, idle connection 538796.000000, request 304398.182631 05/05/2025 02:11:57.187 7f578afe4828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 466 05/05/2025 02:11:57.187 7f578afe4828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:57.188 7f578afe4828 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 466 (602.259635925293 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1087803404, topics=[]) 05/05/2025 02:11:57.188 7f578afe4828 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1087803404 with 0 response partitions (1 implied) 05/05/2025 02:11:57.188 7f578b43e0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59663.570068, idle connection 538796.000000, request 304398.113251 05/05/2025 02:11:57.188 7f578b43e0f0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 460 05/05/2025 02:11:57.188 7f578b43e0f0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:57.188 7f578b43e0f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 460 (602.2059917449951 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2034123924, topics=[]) 05/05/2025 02:11:57.188 7f578b43e0f0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2034123924 with 0 response partitions (1 implied) 05/05/2025 02:11:57.231 7f578af15f60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 219 05/05/2025 02:11:57.231 7f578af15f60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 05/05/2025 02:11:57.231 7f578af15f60 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)]) 05/05/2025 02:11:57.231 7f578af15f60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:57.231 7f578af15f60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=546626154, session_epoch=496, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.231 7f578af15f60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 499 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=546626154, session_epoch=496, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.232 7f578af15f60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59910.998291, idle connection 538195.000000, request 304999.949217 05/05/2025 02:11:57.232 7f578af15f60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59910.593750, idle connection 538195.000000, request 304999.552727 05/05/2025 02:11:57.240 7f578b476d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 17 05/05/2025 02:11:57.240 7f578b476d68 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 05/05/2025 02:11:57.240 7f578b476d68 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)]) 05/05/2025 02:11:57.240 7f578b476d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:57.240 7f578b476d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1394807976, session_epoch=456, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.240 7f578b476d68 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 459 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1394807976, session_epoch=456, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.241 7f578b476d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59170.995850, idle connection 538195.000000, request 304999.959707 05/05/2025 02:11:57.241 7f578b476d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59170.669189, idle connection 538194.000000, request 304999.636889 05/05/2025 02:11:57.279 7f578b3eb978 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59693.938232, idle connection 538797.000000, request 304399.156094 05/05/2025 02:11:57.280 7f578b3eb978 [kafka.protocol.parser] [DEBUG]: Received correlation id: 459 05/05/2025 02:11:57.280 7f578b3eb978 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:57.280 7f578b3eb978 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 459 (601.2821197509766 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=892475593, topics=[]) 05/05/2025 02:11:57.280 7f578b3eb978 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 892475593 with 0 response partitions (1 implied) 05/05/2025 02:11:57.286 7f578b4bbc18 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60171.308838, idle connection 538797.000000, request 304398.391247 05/05/2025 02:11:57.286 7f578b4bbc18 [kafka.protocol.parser] [DEBUG]: Received correlation id: 464 05/05/2025 02:11:57.286 7f578b4bbc18 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:57.286 7f578b4bbc18 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 464 (601.9551753997803 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1438358457, topics=[]) 05/05/2025 02:11:57.286 7f578b4bbc18 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1438358457 with 0 response partitions (1 implied) 05/05/2025 02:11:57.286 7f578b41e630 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60121.617188, idle connection 538797.000000, request 304398.383141 05/05/2025 02:11:57.287 7f578b41e630 [kafka.protocol.parser] [DEBUG]: Received correlation id: 458 05/05/2025 02:11:57.287 7f578b41e630 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:57.287 7f578b41e630 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 458 (601.9153594970703 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=349838626, topics=[]) 05/05/2025 02:11:57.287 7f578b41e630 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 349838626 with 0 response partitions (1 implied) 05/05/2025 02:11:57.293 7f578b42d438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 28 05/05/2025 02:11:57.293 7f578b42d438 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 05/05/2025 02:11:57.293 7f578b42d438 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-13', partition=0)]) 05/05/2025 02:11:57.294 7f578b42d438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:57.294 7f578b42d438 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=170483227, session_epoch=455, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.294 7f578b42d438 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 458 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=170483227, session_epoch=455, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.294 7f578b42d438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59951.493408, idle connection 538194.000000, request 304999.956131 05/05/2025 02:11:57.294 7f578b46f048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 23 05/05/2025 02:11:57.294 7f578b46f048 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 05/05/2025 02:11:57.294 7f578b46f048 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)]) 05/05/2025 02:11:57.294 7f578b46f048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:57.294 7f578b46f048 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=270212331, session_epoch=455, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.295 7f578b46f048 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 458 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=270212331, session_epoch=455, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.295 7f578b46f048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60165.783447, idle connection 538194.000000, request 304999.963760 05/05/2025 02:11:57.295 7f578b42d438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59950.452393, idle connection 538193.000000, request 304998.920441 05/05/2025 02:11:57.295 7f578b41d588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 247 05/05/2025 02:11:57.295 7f578b41d588 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 05/05/2025 02:11:57.295 7f578b41d588 [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)]) 05/05/2025 02:11:57.295 7f578b41d588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:57.295 7f578b41d588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1679627920, session_epoch=486, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.295 7f578b41d588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 489 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1679627920, session_epoch=486, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.296 7f578b41d588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60274.637939, idle connection 538194.000000, request 304999.965429 05/05/2025 02:11:57.296 7f578b444d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 174 05/05/2025 02:11:57.296 7f578b444d68 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 05/05/2025 02:11:57.296 7f578b444d68 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)]) 05/05/2025 02:11:57.296 7f578b444d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:57.296 7f578b444d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1801466066, session_epoch=474, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.296 7f578b444d68 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 477 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1801466066, session_epoch=474, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.296 7f578b444d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59835.404541, idle connection 538194.000000, request 304999.965906 05/05/2025 02:11:57.297 7f578b46f048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60163.844238, idle connection 538192.000000, request 304998.028278 05/05/2025 02:11:57.297 7f578b41d588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60273.242188, idle connection 538192.000000, request 304998.572111 05/05/2025 02:11:57.297 7f578b444d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59834.289307, idle connection 538193.000000, request 304998.853207 05/05/2025 02:11:57.390 7f578b4c7438 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 47 05/05/2025 02:11:57.391 7f578b4c7438 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 05/05/2025 02:11:57.391 7f578b4c7438 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)]) 05/05/2025 02:11:57.391 7f578b4c7438 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:57.391 7f578b4c7438 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1278798477, session_epoch=460, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.391 7f578b4c7438 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 463 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1278798477, session_epoch=460, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.391 7f578b4c7438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60266.339600, idle connection 538195.000000, request 304999.935627 05/05/2025 02:11:57.392 7f578b4c7438 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60265.786865, idle connection 538195.000000, request 304999.391317 05/05/2025 02:11:57.407 7f578b4bb048 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 14 05/05/2025 02:11:57.407 7f578b4bb048 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 05/05/2025 02:11:57.407 7f578b4bb048 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-7', partition=0)]) 05/05/2025 02:11:57.407 7f578b4bb048 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:57.407 7f578b4bb048 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=182402792, session_epoch=454, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.407 7f578b4bb048 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 457 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=182402792, session_epoch=454, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.408 7f578b4bb048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59474.033691, idle connection 538194.000000, request 304999.927521 05/05/2025 02:11:57.408 7f578b4bb048 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59473.281982, idle connection 538194.000000, request 304999.184608 05/05/2025 02:11:57.413 7f578b25a588 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 194 05/05/2025 02:11:57.413 7f578b25a588 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 05/05/2025 02:11:57.413 7f578b25a588 [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)]) 05/05/2025 02:11:57.413 7f578b25a588 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:57.413 7f578b25a588 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1554889754, session_epoch=478, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.414 7f578b25a588 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 481 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1554889754, session_epoch=478, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.414 7f578b25a588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60436.574707, idle connection 538195.000000, request 304999.959707 05/05/2025 02:11:57.414 7f578b25a588 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 60436.156250, idle connection 538195.000000, request 304999.544859 05/05/2025 02:11:57.436 7f578b4a0e10 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 2367 05/05/2025 02:11:57.436 7f578b4a0e10 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 05/05/2025 02:11:57.436 7f578b4a0e10 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)]) 05/05/2025 02:11:57.436 7f578b4a0e10 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:57.436 7f578b4a0e10 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2017973102, session_epoch=672, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.436 7f578b4a0e10 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 675 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2017973102, session_epoch=672, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.436 7f578b4a0e10 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59138.338623, idle connection 538695.000000, request 304999.949694 05/05/2025 02:11:57.437 7f578b4a0e10 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59137.924072, idle connection 538694.000000, request 304999.542475 05/05/2025 02:11:57.440 7f578b4a1828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 23 05/05/2025 02:11:57.440 7f578b4a1828 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 05/05/2025 02:11:57.440 7f578b4a1828 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-18', partition=0)]) 05/05/2025 02:11:57.440 7f578b4a1828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:57.440 7f578b4a1828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=287674646, session_epoch=454, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.440 7f578b4a1828 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 457 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=287674646, session_epoch=454, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.440 7f578b4a1828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59847.154541, idle connection 538194.000000, request 304999.960423 05/05/2025 02:11:57.441 7f578aefbcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59511.097412, idle connection 538796.000000, request 304397.901058 05/05/2025 02:11:57.441 7f578b4a1828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59846.677979, idle connection 538194.000000, request 304999.488354 05/05/2025 02:11:57.441 7f578aefbcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 479 05/05/2025 02:11:57.441 7f578aefbcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:57.441 7f578aefbcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 479 (602.7584075927734 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=277208274, topics=[]) 05/05/2025 02:11:57.441 7f578aefbcc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 277208274 with 0 response partitions (1 implied) 05/05/2025 02:11:57.454 7f578aea1198 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 137 05/05/2025 02:11:57.455 7f578aea1198 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 05/05/2025 02:11:57.455 7f578aea1198 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-21', partition=0)]) 05/05/2025 02:11:57.455 7f578aea1198 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:57.455 7f578aea1198 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1832307886, session_epoch=484, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.455 7f578aea1198 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 487 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1832307886, session_epoch=484, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.455 7f578aea1198 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59535.275146, idle connection 538196.000000, request 304999.958992 05/05/2025 02:11:57.456 7f578aea1198 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59534.939209, idle connection 538195.000000, request 304999.627590 05/05/2025 02:11:57.460 7f578b3c8d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59346.569824, idle connection 538797.000000, request 304399.109602 05/05/2025 02:11:57.460 7f578b3c8d68 [kafka.protocol.parser] [DEBUG]: Received correlation id: 456 05/05/2025 02:11:57.460 7f578b3c8d68 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:57.460 7f578b3c8d68 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 456 (601.2842655181885 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1877425480, topics=[]) 05/05/2025 02:11:57.460 7f578b3c8d68 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1877425480 with 0 response partitions (1 implied) 05/05/2025 02:11:57.513 7f578b4a50f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 129 05/05/2025 02:11:57.513 7f578b4a50f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 05/05/2025 02:11:57.513 7f578b4a50f0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-2', partition=0)]) 05/05/2025 02:11:57.514 7f578b4a50f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:57.514 7f578b4a50f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1369124269, session_epoch=476, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.514 7f578b4a50f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 479 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1369124269, session_epoch=476, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.514 7f578b4a50f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59013.557617, idle connection 538195.000000, request 304999.949932 05/05/2025 02:11:57.514 7f578b4a50f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59013.140869, idle connection 538195.000000, request 304999.541759 05/05/2025 02:11:57.551 7f578b7a42e8 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 16 05/05/2025 02:11:57.551 7f578b7a42e8 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 05/05/2025 02:11:57.551 7f578b7a42e8 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-4', partition=0)]) 05/05/2025 02:11:57.551 7f578b7a42e8 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:57.551 7f578b7a42e8 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1754878510, session_epoch=454, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.551 7f578b7a42e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 457 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1754878510, session_epoch=454, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.552 7f578b7a42e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59760.134521, idle connection 538195.000000, request 304999.947309 05/05/2025 02:11:57.552 7f578b7a42e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59759.690918, idle connection 538195.000000, request 304999.512196 05/05/2025 02:11:57.565 7f578afd6390 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 21 05/05/2025 02:11:57.565 7f578afd6390 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 05/05/2025 02:11:57.565 7f578afd6390 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-17', partition=0)]) 05/05/2025 02:11:57.565 7f578afd6390 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:57.565 7f578afd6390 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1604738415, session_epoch=455, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.565 7f578afd6390 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 458 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1604738415, session_epoch=455, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.565 7f578afd6390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59014.961426, idle connection 538196.000000, request 304999.957085 05/05/2025 02:11:57.566 7f578afd6390 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59014.497314, idle connection 538195.000000, request 304999.496937 05/05/2025 02:11:57.572 7f578b42d2e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59235.972900, idle connection 538796.000000, request 304398.113489 05/05/2025 02:11:57.573 7f578b42d2e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 454 05/05/2025 02:11:57.573 7f578b42d2e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:57.573 7f578b42d2e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 454 (602.2565364837646 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=739843525, topics=[]) 05/05/2025 02:11:57.573 7f578b42d2e8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 739843525 with 0 response partitions (1 implied) 05/05/2025 02:11:57.573 7f578adb42e8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59979.180664, idle connection 538796.000000, request 304398.123503 05/05/2025 02:11:57.573 7f578adb42e8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 485 05/05/2025 02:11:57.573 7f578adb42e8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:57.573 7f578adb42e8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 485 (602.1890640258789 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1209576856, topics=[]) 05/05/2025 02:11:57.574 7f578adb42e8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1209576856 with 0 response partitions (1 implied) 05/05/2025 02:11:57.679 7f578b3d26d8 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59756.892578, idle connection 538797.000000, request 304398.889780 05/05/2025 02:11:57.679 7f578b3d26d8 [kafka.protocol.parser] [DEBUG]: Received correlation id: 477 05/05/2025 02:11:57.679 7f578b3d26d8 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:57.679 7f578b3d26d8 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 477 (601.6538143157959 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=522221117, topics=[]) 05/05/2025 02:11:57.679 7f578b3d26d8 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 522221117 with 0 response partitions (1 implied) 05/05/2025 02:11:57.715 7f578b3e1828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59667.605957, idle connection 537592.000000, request 304398.962021 05/05/2025 02:11:57.715 7f578b3e1828 [kafka.protocol.parser] [DEBUG]: Received correlation id: 458 05/05/2025 02:11:57.715 7f578b3e1828 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:57.715 7f578b3e1828 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 458 (601.5396118164062 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1889094295, topics=[]) 05/05/2025 02:11:57.716 7f578b3e1828 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1889094295 with 0 response partitions (1 implied) 05/05/2025 02:11:57.716 7f5796863cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 05/05/2025 02:11:57.716 7f5796863cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 05/05/2025 02:11:57.716 7f5796863cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-1', partition=0)]) 05/05/2025 02:11:57.716 7f5796863cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:57.716 7f5796863cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1265972283, session_epoch=450, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.716 7f5796863cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 453 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1265972283, session_epoch=450, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.716 7f5796863cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 58698.221436, idle connection 538192.000000, request 304999.953985 05/05/2025 02:11:57.717 7f578b3a9cc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 05/05/2025 02:11:57.717 7f578b3a9cc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 05/05/2025 02:11:57.717 7f578b3a9cc0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-3', partition=0)]) 05/05/2025 02:11:57.717 7f578b3a9cc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:57.717 7f578b3a9cc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=286255758, session_epoch=450, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.717 7f578b3a9cc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 453 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=286255758, session_epoch=450, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.717 7f578b3a9cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 58724.376465, idle connection 538193.000000, request 304999.963284 05/05/2025 02:11:57.717 7f578ae92d68 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 33 05/05/2025 02:11:57.717 7f578ae92d68 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 05/05/2025 02:11:57.717 7f578ae92d68 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-24', partition=0)]) 05/05/2025 02:11:57.718 7f578ae92d68 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:57.718 7f578ae92d68 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=390896471, session_epoch=457, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.718 7f578ae92d68 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 460 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=390896471, session_epoch=457, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.718 7f578ae92d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59859.126709, idle connection 538193.000000, request 304999.964714 05/05/2025 02:11:57.718 7f5796863cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 58696.491943, idle connection 538191.000000, request 304998.230696 05/05/2025 02:11:57.719 7f578b3a9cc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 58722.930420, idle connection 538191.000000, request 304998.520851 05/05/2025 02:11:57.719 7f578ae92d68 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59857.645508, idle connection 538191.000000, request 304998.486996 05/05/2025 02:11:57.720 7f578b28c240 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 76 05/05/2025 02:11:57.720 7f578b28c240 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 05/05/2025 02:11:57.720 7f578b28c240 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-16', partition=0)]) 05/05/2025 02:11:57.720 7f578b28c240 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:57.720 7f578b28c240 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1799898802, session_epoch=466, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.720 7f578b28c240 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 469 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1799898802, session_epoch=466, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.720 7f578b28c240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59946.133057, idle connection 538195.000000, request 304999.955177 05/05/2025 02:11:57.721 7f578b28c240 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59945.688477, idle connection 538195.000000, request 304999.513865 05/05/2025 02:11:57.788 7f578afe4828 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 68 05/05/2025 02:11:57.788 7f578afe4828 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 05/05/2025 02:11:57.788 7f578afe4828 [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)]) 05/05/2025 02:11:57.789 7f578afe4828 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:57.789 7f578afe4828 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1087803404, session_epoch=464, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.789 7f578afe4828 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 467 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1087803404, session_epoch=464, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.789 7f578afe4828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59231.375488, idle connection 538194.000000, request 304999.946117 05/05/2025 02:11:57.789 7f578afe4828 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59230.822021, idle connection 538194.000000, request 304999.400854 05/05/2025 02:11:57.790 7f578b43e0f0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 40 05/05/2025 02:11:57.790 7f578b43e0f0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 05/05/2025 02:11:57.790 7f578b43e0f0 [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)]) 05/05/2025 02:11:57.790 7f578b43e0f0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 05/05/2025 02:11:57.790 7f578b43e0f0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2034123924, session_epoch=458, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.790 7f578b43e0f0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Request 461 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2034123924, session_epoch=458, topics=[], forgotten_topics_data=[]) 05/05/2025 02:11:57.790 7f578b43e0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59061.304932, idle connection 538194.000000, request 304999.960423 05/05/2025 02:11:57.791 7f578b43e0f0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59060.777588, idle connection 538193.000000, request 304999.437571 05/05/2025 02:11:57.833 7f578af15f60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 59309.429443, idle connection 537594.000000, request 304398.379087 05/05/2025 02:11:57.833 7f578af15f60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 499 05/05/2025 02:11:57.834 7f578af15f60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 05/05/2025 02:11:57.834 7f578af15f60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.38', 9092)]>: Response 499 (602.1542549133301 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=546626154, topics=[]) 05/05/2025 02:11:57.834 7f578af15f60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 546626154 with 0 response partitions (1 implied)