03/19/2026 02:21:36.269 7f2caef3f540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1118 (607.6326370239258 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=384935743, topics=[]) 03/19/2026 02:21:36.270 7f2caef3f540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 384935743 with 0 response partitions (1 implied) 03/19/2026 02:21:36.272 7f2caef1b5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175460.121338, idle connection 291098.000000, request 304398.775339 03/19/2026 02:21:36.273 7f2caef1b5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1119 03/19/2026 02:21:36.273 7f2caef1b5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:36.273 7f2caef1b5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1119 (601.6592979431152 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1934074637, topics=[]) 03/19/2026 02:21:36.273 7f2caef1b5e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1934074637 with 0 response partitions (1 implied) 03/19/2026 02:21:36.274 7f2caf793360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 142 03/19/2026 02:21:36.274 7f2caf793360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 03/19/2026 02:21:36.274 7f2caf793360 [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)]) 03/19/2026 02:21:36.274 7f2caf793360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:36.274 7f2caf793360 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=682885807, session_epoch=1132, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.275 7f2caf793360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1138 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=682885807, session_epoch=1132, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.275 7f2caf793360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176276.655029, idle connection 290320.000000, request 304999.943495 03/19/2026 02:21:36.275 7f2caf793360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176276.223633, idle connection 290320.000000, request 304999.517202 03/19/2026 02:21:36.329 7f2caef3f0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177445.733887, idle connection 292367.000000, request 304397.680283 03/19/2026 02:21:36.329 7f2caef3f0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1133 03/19/2026 02:21:36.329 7f2caef3f0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:36.329 7f2caef3f0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1133 (602.898120880127 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=253125093, topics=[]) 03/19/2026 02:21:36.329 7f2caef3f0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 253125093 with 0 response partitions (1 implied) 03/19/2026 02:21:36.339 7f2cad7155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177189.495361, idle connection 291033.000000, request 304398.345232 03/19/2026 02:21:36.339 7f2cad7155e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1117 03/19/2026 02:21:36.339 7f2cad7155e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:36.340 7f2cad7155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1117 (602.2017002105713 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=542859706, topics=[]) 03/19/2026 02:21:36.340 7f2cad7155e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 542859706 with 0 response partitions (1 implied) 03/19/2026 02:21:36.346 7f2caef3f860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 142 03/19/2026 02:21:36.346 7f2caef3f860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 03/19/2026 02:21:36.346 7f2caef3f860 [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)]) 03/19/2026 02:21:36.347 7f2caef3f860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:36.347 7f2caef3f860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=709173073, session_epoch=1137, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.347 7f2caef3f860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1143 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=709173073, session_epoch=1137, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.347 7f2caef3f860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176301.840332, idle connection 292148.000000, request 304999.947071 03/19/2026 02:21:36.347 7f2caef3f860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176301.403564, idle connection 292147.000000, request 304999.517441 03/19/2026 02:21:36.374 7f2caf793f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177324.662109, idle connection 292032.000000, request 304398.537636 03/19/2026 02:21:36.374 7f2caf793f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1151 03/19/2026 02:21:36.374 7f2caf793f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:36.374 7f2caf793f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1151 (601.9730567932129 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1676342825, topics=[]) 03/19/2026 02:21:36.374 7f2caf793f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1676342825 with 0 response partitions (1 implied) 03/19/2026 02:21:36.392 7f2caf793680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177603.727051, idle connection 292085.000000, request 304398.441076 03/19/2026 02:21:36.392 7f2caf793680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1108 03/19/2026 02:21:36.392 7f2caf793680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:36.392 7f2caf793680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1108 (602.0548343658447 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=463264883, topics=[]) 03/19/2026 02:21:36.392 7f2caf793680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 463264883 with 0 response partitions (1 implied) 03/19/2026 02:21:36.417 7f2caf793a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175858.056641, idle connection 290875.000000, request 304398.002148 03/19/2026 02:21:36.417 7f2caf793a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1139 03/19/2026 02:21:36.418 7f2caf793a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:36.418 7f2caf793a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1139 (602.5543212890625 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1117879767, topics=[]) 03/19/2026 02:21:36.418 7f2caf793a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1117879767 with 0 response partitions (1 implied) 03/19/2026 02:21:36.465 7f2caf793040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176327.219971, idle connection 291722.000000, request 304398.827076 03/19/2026 02:21:36.465 7f2caf793040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1142 03/19/2026 02:21:36.465 7f2caf793040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:36.466 7f2caf793040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1142 (602.1335124969482 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1725896610, topics=[]) 03/19/2026 02:21:36.466 7f2caf793040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1725896610 with 0 response partitions (1 implied) 03/19/2026 02:21:36.572 7f2caef3f5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176082.809814, idle connection 290720.000000, request 304398.901701 03/19/2026 02:21:36.573 7f2caef3f5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1191 03/19/2026 02:21:36.573 7f2caef3f5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:36.573 7f2caef3f5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1191 (601.6693115234375 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1088720252, topics=[]) 03/19/2026 02:21:36.573 7f2caef3f5e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1088720252 with 0 response partitions (1 implied) 03/19/2026 02:21:36.589 7f2cad715540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175681.937256, idle connection 290260.000000, request 304398.895025 03/19/2026 02:21:36.590 7f2cad715540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1105 03/19/2026 02:21:36.590 7f2cad715540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:36.590 7f2cad715540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1105 (601.6695499420166 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1560518070, topics=[]) 03/19/2026 02:21:36.590 7f2cad715540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1560518070 with 0 response partitions (1 implied) 03/19/2026 02:21:36.625 7f2cad7154a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 2 03/19/2026 02:21:36.625 7f2cad7154a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 03/19/2026 02:21:36.625 7f2cad7154a0 [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)]) 03/19/2026 02:21:36.625 7f2cad7154a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:36.625 7f2cad7154a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1615957650, session_epoch=1098, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.625 7f2cad7154a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1104 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1615957650, session_epoch=1098, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.626 7f2cad7154a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177363.523682, idle connection 290466.000000, request 304999.933720 03/19/2026 02:21:36.626 7f2caf793c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 30 03/19/2026 02:21:36.626 7f2caf793c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 03/19/2026 02:21:36.626 7f2caf793c20 [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)]) 03/19/2026 02:21:36.626 7f2caf793c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:36.626 7f2caf793c20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2052040693, session_epoch=1105, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.626 7f2caf793c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1111 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2052040693, session_epoch=1105, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.626 7f2caf793c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176161.261719, idle connection 291068.000000, request 304999.963760 03/19/2026 02:21:36.626 7f2cad09d9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 03/19/2026 02:21:36.626 7f2cad09d9a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 03/19/2026 02:21:36.626 7f2cad09d9a0 [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)]) 03/19/2026 02:21:36.626 7f2cad09d9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:36.627 7f2cad09d9a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1244083730, session_epoch=1098, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.627 7f2cad09d9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1104 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1244083730, session_epoch=1098, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.627 7f2cad09d9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176162.363770, idle connection 290644.000000, request 304999.963045 03/19/2026 02:21:36.627 7f2cad7154a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177361.922852, idle connection 290465.000000, request 304998.343229 03/19/2026 02:21:36.627 7f2caef1b7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 11 03/19/2026 02:21:36.627 7f2caef1b7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 03/19/2026 02:21:36.627 7f2caef1b7c0 [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)]) 03/19/2026 02:21:36.627 7f2caef1b7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:36.628 7f2caef1b7c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=374391613, session_epoch=1102, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.628 7f2caef1b7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1108 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=374391613, session_epoch=1102, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.628 7f2caef1b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177369.915283, idle connection 289964.000000, request 304999.966145 03/19/2026 02:21:36.628 7f2caf793c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176159.416016, idle connection 291066.000000, request 304998.121500 03/19/2026 02:21:36.628 7f2cad09d9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176160.836182, idle connection 290642.000000, request 304998.434544 03/19/2026 02:21:36.628 7f2caf793860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 55 03/19/2026 02:21:36.629 7f2caf793860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 03/19/2026 02:21:36.629 7f2caf793860 [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)]) 03/19/2026 02:21:36.629 7f2caf793860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:36.629 7f2caf793860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=179484960, session_epoch=1113, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.629 7f2caf793860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1119 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=179484960, session_epoch=1113, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.629 7f2caf793860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176167.124023, idle connection 291174.000000, request 304999.968290 03/19/2026 02:21:36.629 7f2caf793180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175691.815674, idle connection 291464.000000, request 304397.101879 03/19/2026 02:21:36.629 7f2caef1b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177368.383057, idle connection 289962.000000, request 304998.436451 03/19/2026 02:21:36.630 7f2caf793180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1116 03/19/2026 02:21:36.630 7f2caf793180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:36.630 7f2caf793180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1116 (603.6686897277832 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1036523930, topics=[]) 03/19/2026 02:21:36.630 7f2caf793180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1036523930 with 0 response partitions (1 implied) 03/19/2026 02:21:36.630 7f2caf793860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176165.775391, idle connection 291173.000000, request 304998.620749 03/19/2026 02:21:36.648 7f2caf793540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 24 03/19/2026 02:21:36.648 7f2caf793540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 03/19/2026 02:21:36.648 7f2caf793540 [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)]) 03/19/2026 02:21:36.648 7f2caf793540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:36.648 7f2caf793540 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1607225837, session_epoch=1107, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.648 7f2caf793540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1113 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1607225837, session_epoch=1107, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.648 7f2caf793540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176152.822266, idle connection 291948.000000, request 304999.948978 03/19/2026 02:21:36.649 7f2caf793540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176152.363525, idle connection 291948.000000, request 304999.500036 03/19/2026 02:21:36.652 7f2cad09dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176886.760498, idle connection 291450.000000, request 304399.073601 03/19/2026 02:21:36.652 7f2cad09dc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1103 03/19/2026 02:21:36.652 7f2cad09dc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:36.652 7f2cad09dc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1103 (601.2694835662842 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=794221359, topics=[]) 03/19/2026 02:21:36.652 7f2cad09dc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 794221359 with 0 response partitions (1 implied) 03/19/2026 02:21:36.656 7f2caf793b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 56 03/19/2026 02:21:36.656 7f2caf793b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 03/19/2026 02:21:36.656 7f2caf793b80 [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)]) 03/19/2026 02:21:36.656 7f2caf793b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:36.656 7f2caf793b80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=900741920, session_epoch=1109, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.656 7f2caf793b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1115 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=900741920, session_epoch=1109, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.656 7f2caf793b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176146.383301, idle connection 290648.000000, request 304999.959230 03/19/2026 02:21:36.657 7f2caf793b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176146.017822, idle connection 290647.000000, request 304999.594450 03/19/2026 02:21:36.681 7f2caef3fa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175488.688477, idle connection 290510.000000, request 304398.839235 03/19/2026 02:21:36.681 7f2caef3fa40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1190 03/19/2026 02:21:36.681 7f2caef3fa40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:36.681 7f2caef3fa40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1190 (601.7129421234131 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1543415504, topics=[]) 03/19/2026 02:21:36.681 7f2caef3fa40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1543415504 with 0 response partitions (1 implied) 03/19/2026 02:21:36.709 7f2cad09d720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175752.368896, idle connection 290363.000000, request 304398.747683 03/19/2026 02:21:36.710 7f2cad09d720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1572 03/19/2026 02:21:36.710 7f2cad09d720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:36.710 7f2cad09d720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1572 (601.7587184906006 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=65780457, topics=[]) 03/19/2026 02:21:36.710 7f2cad09d720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 65780457 with 0 response partitions (1 implied) 03/19/2026 02:21:36.762 7f2cad09db80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 218 03/19/2026 02:21:36.762 7f2cad09db80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 03/19/2026 02:21:36.763 7f2cad09db80 [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)]) 03/19/2026 02:21:36.763 7f2cad09db80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:36.763 7f2cad09db80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=333243271, session_epoch=1148, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.763 7f2cad09db80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1154 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=333243271, session_epoch=1148, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.763 7f2cad09db80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176558.518311, idle connection 291217.000000, request 304999.926329 03/19/2026 02:21:36.764 7f2cad09dcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 35 03/19/2026 02:21:36.764 7f2cad09dcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 03/19/2026 02:21:36.764 7f2cad09dcc0 [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)]) 03/19/2026 02:21:36.764 7f2cad09dcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:36.764 7f2cad09dcc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1137906728, session_epoch=1110, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.764 7f2cad09dcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1116 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1137906728, session_epoch=1110, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.764 7f2cad09dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176302.243408, idle connection 291311.000000, request 304999.949932 03/19/2026 02:21:36.765 7f2cad09db80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176557.156250, idle connection 291216.000000, request 304998.576880 03/19/2026 02:21:36.765 7f2cad09dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176301.299316, idle connection 291310.000000, request 304999.011755 03/19/2026 02:21:36.773 7f2cad09d900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 03/19/2026 02:21:36.773 7f2cad09d900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 03/19/2026 02:21:36.774 7f2cad09d900 [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)]) 03/19/2026 02:21:36.774 7f2cad09d900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:36.774 7f2cad09d900 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=824437575, session_epoch=1098, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.774 7f2cad09d900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1104 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=824437575, session_epoch=1098, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.774 7f2cad09d900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175341.196045, idle connection 289893.000000, request 304999.958515 03/19/2026 02:21:36.774 7f2cad09d900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175340.860840, idle connection 289893.000000, request 304999.629498 03/19/2026 02:21:36.791 7f2caef1b860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176008.301270, idle connection 290409.000000, request 304398.868322 03/19/2026 02:21:36.792 7f2caef1b860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1112 03/19/2026 02:21:36.792 7f2caef1b860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:36.792 7f2caef1b860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1112 (601.5729904174805 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=195078769, topics=[]) 03/19/2026 02:21:36.792 7f2caef1b860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 195078769 with 0 response partitions (1 implied) 03/19/2026 02:21:36.839 7f2caef3f680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 482 03/19/2026 02:21:36.871 7f2caef3f680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 03/19/2026 02:21:36.871 7f2caef3f680 [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)]) 03/19/2026 02:21:36.871 7f2caef3f680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:36.871 7f2caef3f680 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=828351460, session_epoch=1187, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.871 7f2caef3f680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1193 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=828351460, session_epoch=1187, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.872 7f2caef3f680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176295.704102, idle connection 289977.000000, request 304999.940634 03/19/2026 02:21:36.872 7f2caf793d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 141 03/19/2026 02:21:36.872 7f2caf793d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 03/19/2026 02:21:36.872 7f2caf793d60 [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)]) 03/19/2026 02:21:36.872 7f2caf793d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:36.872 7f2caf793d60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2014497448, session_epoch=1137, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.872 7f2caf793d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1143 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2014497448, session_epoch=1137, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.872 7f2caf793d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176130.365234, idle connection 290928.000000, request 304999.961615 03/19/2026 02:21:36.873 7f2caf793ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 50 03/19/2026 02:21:36.873 7f2caf793ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 03/19/2026 02:21:36.873 7f2caf793ae0 [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)]) 03/19/2026 02:21:36.873 7f2caf793ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:36.873 7f2caf793ae0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1366366715, session_epoch=1116, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.873 7f2caf793ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1122 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1366366715, session_epoch=1116, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.873 7f2caf793ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175530.920166, idle connection 291422.000000, request 304999.966621 03/19/2026 02:21:36.873 7f2caef3f540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 65 03/19/2026 02:21:36.873 7f2caef3f540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 03/19/2026 02:21:36.873 7f2caef3f540 [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)]) 03/19/2026 02:21:36.873 7f2caef3f540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:36.873 7f2caef3f540 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=384935743, session_epoch=1113, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.873 7f2caef3f540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1119 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=384935743, session_epoch=1113, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.874 7f2caef3f540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175996.545898, idle connection 291227.000000, request 304999.965668 03/19/2026 02:21:36.874 7f2caef3f680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176293.313477, idle connection 289975.000000, request 304997.558594 03/19/2026 02:21:36.874 7f2caef1b5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 34 03/19/2026 02:21:36.874 7f2caef1b5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 03/19/2026 02:21:36.874 7f2caef1b5e0 [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)]) 03/19/2026 02:21:36.874 7f2caef1b5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:36.874 7f2caef1b5e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1934074637, session_epoch=1114, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.875 7f2caef1b5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1120 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1934074637, session_epoch=1114, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.875 7f2caef1b5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174857.941650, idle connection 290496.000000, request 304999.967575 03/19/2026 02:21:36.875 7f2caf793d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176127.713867, idle connection 290926.000000, request 304997.315168 03/19/2026 02:21:36.875 7f2caf793ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175528.614014, idle connection 291419.000000, request 304997.663736 03/19/2026 02:21:36.876 7f2caef3f540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175994.580322, idle connection 291225.000000, request 304998.003483 03/19/2026 02:21:36.876 7f2caf793360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175675.530273, idle connection 289719.000000, request 304398.826361 03/19/2026 02:21:36.876 7f2caef1b5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174856.539551, idle connection 290495.000000, request 304998.568535 03/19/2026 02:21:36.876 7f2caf793360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1138 03/19/2026 02:21:36.877 7f2caf793360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:36.877 7f2caf793360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1138 (601.9177436828613 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=682885807, topics=[]) 03/19/2026 02:21:36.877 7f2caf793360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 682885807 with 0 response partitions (1 implied) 03/19/2026 02:21:36.930 7f2caef3f0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 84 03/19/2026 02:21:36.954 7f2caef3f0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 03/19/2026 02:21:36.955 7f2caef3f0e0 [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)]) 03/19/2026 02:21:36.955 7f2caef3f0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:36.955 7f2caef3f0e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=253125093, session_epoch=1128, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.955 7f2caef3f0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1134 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=253125093, session_epoch=1128, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.955 7f2caef3f0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176818.880859, idle connection 291740.000000, request 304999.917746 03/19/2026 02:21:36.956 7f2cad7155e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 34 03/19/2026 02:21:36.956 7f2cad7155e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 03/19/2026 02:21:36.956 7f2cad7155e0 [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)]) 03/19/2026 02:21:36.956 7f2cad7155e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:36.956 7f2cad7155e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=542859706, session_epoch=1112, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.956 7f2cad7155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1118 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=542859706, session_epoch=1112, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.956 7f2cad7155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176572.145264, idle connection 290415.000000, request 304999.949455 03/19/2026 02:21:36.957 7f2caef3f860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175692.177246, idle connection 291538.000000, request 304390.289783 03/19/2026 02:21:36.957 7f2caef3f0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176817.285889, idle connection 291738.000000, request 304998.340845 03/19/2026 02:21:36.957 7f2caef3f860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1143 03/19/2026 02:21:36.957 7f2caef3f860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:36.957 7f2caef3f860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1143 (610.5690002441406 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=709173073, topics=[]) 03/19/2026 02:21:36.958 7f2caef3f860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 709173073 with 0 response partitions (1 implied) 03/19/2026 02:21:36.958 7f2cad7155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176570.522461, idle connection 290414.000000, request 304998.333693 03/19/2026 02:21:36.975 7f2caf793f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 162 03/19/2026 02:21:36.976 7f2caf793f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 03/19/2026 02:21:36.976 7f2caf793f40 [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)]) 03/19/2026 02:21:36.976 7f2caf793f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:36.976 7f2caf793f40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1676342825, session_epoch=1146, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.976 7f2caf793f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1152 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1676342825, session_epoch=1146, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.976 7f2caf793f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176721.786621, idle connection 291429.000000, request 304999.941826 03/19/2026 02:21:36.977 7f2caf793f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176721.239502, idle connection 291428.000000, request 304999.403000 03/19/2026 02:21:36.994 7f2caf793680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 18 03/19/2026 02:21:36.994 7f2caf793680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 03/19/2026 02:21:36.994 7f2caf793680 [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)]) 03/19/2026 02:21:36.994 7f2caf793680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:36.994 7f2caf793680 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=463264883, session_epoch=1103, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.994 7f2caf793680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1109 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=463264883, session_epoch=1103, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:36.995 7f2caf793680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177000.884033, idle connection 291482.000000, request 304999.933720 03/19/2026 02:21:36.995 7f2caf793680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 177000.328613, idle connection 291482.000000, request 304999.387980 03/19/2026 02:21:37.019 7f2caf793a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 132 03/19/2026 02:21:37.025 7f2caf793a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 03/19/2026 02:21:37.025 7f2caf793a40 [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)]) 03/19/2026 02:21:37.026 7f2caf793a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:37.026 7f2caf793a40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1117879767, session_epoch=1134, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.026 7f2caf793a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1140 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1117879767, session_epoch=1134, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.026 7f2caf793a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175249.091553, idle connection 290266.000000, request 304999.936342 03/19/2026 02:21:37.027 7f2caf793a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175248.647705, idle connection 290265.000000, request 304999.502420 03/19/2026 02:21:37.067 7f2caf793040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 164 03/19/2026 02:21:37.068 7f2caf793040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 03/19/2026 02:21:37.068 7f2caf793040 [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)]) 03/19/2026 02:21:37.068 7f2caf793040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:37.068 7f2caf793040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1725896610, session_epoch=1137, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.068 7f2caf793040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1143 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1725896610, session_epoch=1137, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.068 7f2caf793040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175723.732910, idle connection 291118.000000, request 304999.930859 03/19/2026 02:21:37.069 7f2caf793040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175723.283203, idle connection 291118.000000, request 304999.493599 03/19/2026 02:21:37.173 7f2caef3f5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 416 03/19/2026 02:21:37.174 7f2caef3f5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 03/19/2026 02:21:37.174 7f2caef3f5e0 [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)]) 03/19/2026 02:21:37.174 7f2caef3f5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:37.174 7f2caef3f5e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1088720252, session_epoch=1186, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.174 7f2caef3f5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1192 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1088720252, session_epoch=1186, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.174 7f2caef3f5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175480.822754, idle connection 290118.000000, request 304999.945641 03/19/2026 02:21:37.175 7f2caef3f5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175480.374512, idle connection 290118.000000, request 304999.509096 03/19/2026 02:21:37.190 7f2cad715540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 6 03/19/2026 02:21:37.191 7f2cad715540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 03/19/2026 02:21:37.191 7f2cad715540 [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)]) 03/19/2026 02:21:37.191 7f2cad715540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:37.191 7f2cad715540 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1560518070, session_epoch=1100, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.191 7f2cad715540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1106 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1560518070, session_epoch=1100, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.191 7f2cad715540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175080.165527, idle connection 289658.000000, request 304999.934673 03/19/2026 02:21:37.192 7f2cad715540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175079.721436, idle connection 289658.000000, request 304999.505281 03/19/2026 02:21:37.229 7f2cad7154a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176760.232422, idle connection 289863.000000, request 304396.642923 03/19/2026 02:21:37.229 7f2cad7154a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1104 03/19/2026 02:21:37.229 7f2cad7154a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:37.229 7f2cad7154a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1104 (603.9538383483887 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1615957650, topics=[]) 03/19/2026 02:21:37.230 7f2cad7154a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1615957650 with 0 response partitions (1 implied) 03/19/2026 02:21:37.230 7f2caf793c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175557.615967, idle connection 290464.000000, request 304396.315098 03/19/2026 02:21:37.230 7f2cad09d9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175559.132080, idle connection 290041.000000, request 304396.732330 03/19/2026 02:21:37.230 7f2caf793c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1111 03/19/2026 02:21:37.230 7f2caf793c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:37.230 7f2caf793c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1111 (604.1140556335449 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2052040693, topics=[]) 03/19/2026 02:21:37.230 7f2caf793c20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2052040693 with 0 response partitions (1 implied) 03/19/2026 02:21:37.231 7f2cad09d9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1104 03/19/2026 02:21:37.231 7f2cad09d9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:37.231 7f2cad09d9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1104 (603.9958000183105 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1244083730, topics=[]) 03/19/2026 02:21:37.231 7f2cad09d9a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1244083730 with 0 response partitions (1 implied) 03/19/2026 02:21:37.231 7f2caf793180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 72 03/19/2026 02:21:37.231 7f2caf793180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 03/19/2026 02:21:37.231 7f2caf793180 [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)]) 03/19/2026 02:21:37.231 7f2caf793180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:37.231 7f2caf793180 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1036523930, session_epoch=1111, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.231 7f2caf793180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1117 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1036523930, session_epoch=1111, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.231 7f2caf793180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175089.352539, idle connection 290862.000000, request 304999.950171 03/19/2026 02:21:37.232 7f2caef1b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176765.649658, idle connection 289360.000000, request 304395.700693 03/19/2026 02:21:37.232 7f2caf793860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175563.842041, idle connection 290571.000000, request 304396.686792 03/19/2026 02:21:37.232 7f2caef1b7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1108 03/19/2026 02:21:37.232 7f2caef1b7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:37.232 7f2caef1b7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1108 (604.71510887146 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=374391613, topics=[]) 03/19/2026 02:21:37.233 7f2caef1b7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 374391613 with 0 response partitions (1 implied) 03/19/2026 02:21:37.233 7f2caf793860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1119 03/19/2026 02:21:37.233 7f2caf793860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:37.233 7f2caf793860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1119 (603.9958000183105 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=179484960, topics=[]) 03/19/2026 02:21:37.233 7f2caf793860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 179484960 with 0 response partitions (1 implied) 03/19/2026 02:21:37.234 7f2caf793180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175087.126953, idle connection 290859.000000, request 304997.738123 03/19/2026 02:21:37.249 7f2caf793540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175551.820557, idle connection 291347.000000, request 304398.948431 03/19/2026 02:21:37.250 7f2caf793540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1113 03/19/2026 02:21:37.250 7f2caf793540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:37.250 7f2caf793540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1113 (601.6881465911865 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1607225837, topics=[]) 03/19/2026 02:21:37.250 7f2caf793540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1607225837 with 0 response partitions (1 implied) 03/19/2026 02:21:37.252 7f2cad09dc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 0 03/19/2026 02:21:37.253 7f2cad09dc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 03/19/2026 02:21:37.253 7f2cad09dc20 [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)]) 03/19/2026 02:21:37.253 7f2cad09dc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:37.253 7f2cad09dc20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=794221359, session_epoch=1098, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.253 7f2cad09dc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1104 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=794221359, session_epoch=1098, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.253 7f2cad09dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176285.317627, idle connection 290849.000000, request 304999.947786 03/19/2026 02:21:37.254 7f2cad09dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176284.908936, idle connection 290848.000000, request 304999.545813 03/19/2026 02:21:37.257 7f2caf793b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175545.601807, idle connection 290047.000000, request 304399.174452 03/19/2026 02:21:37.257 7f2caf793b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1115 03/19/2026 02:21:37.257 7f2caf793b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:37.258 7f2caf793b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1115 (601.3271808624268 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=900741920, topics=[]) 03/19/2026 02:21:37.258 7f2caf793b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 900741920 with 0 response partitions (1 implied) 03/19/2026 02:21:37.282 7f2caef3fa40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 372 03/19/2026 02:21:37.282 7f2caef3fa40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 03/19/2026 02:21:37.282 7f2caef3fa40 [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)]) 03/19/2026 02:21:37.282 7f2caef3fa40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:37.282 7f2caef3fa40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1543415504, session_epoch=1185, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.282 7f2caef3fa40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1191 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1543415504, session_epoch=1185, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.282 7f2caef3fa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174886.907959, idle connection 289909.000000, request 304999.949694 03/19/2026 02:21:37.283 7f2caef3fa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174886.471436, idle connection 289908.000000, request 304999.521255 03/19/2026 02:21:37.314 7f2cad09d720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3808 03/19/2026 02:21:37.314 7f2cad09d720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 03/19/2026 02:21:37.314 7f2cad09d720 [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)]) 03/19/2026 02:21:37.314 7f2cad09d720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:37.314 7f2cad09d720 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=65780457, session_epoch=1567, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.314 7f2cad09d720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1573 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=65780457, session_epoch=1567, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.315 7f2cad09d720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175147.090088, idle connection 289757.000000, request 304999.926090 03/19/2026 02:21:37.315 7f2cad09d720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175146.532715, idle connection 289757.000000, request 304999.380112 03/19/2026 02:21:37.373 7f2cad09db80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175949.131104, idle connection 290608.000000, request 304390.541315 03/19/2026 02:21:37.373 7f2cad09db80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1154 03/19/2026 02:21:37.373 7f2cad09db80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:37.373 7f2cad09db80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1154 (610.0306510925293 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=333243271, topics=[]) 03/19/2026 02:21:37.373 7f2cad09db80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 333243271 with 0 response partitions (1 implied) 03/19/2026 02:21:37.374 7f2cad09dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175692.818848, idle connection 290702.000000, request 304390.530825 03/19/2026 02:21:37.374 7f2cad09dcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1116 03/19/2026 02:21:37.374 7f2cad09dcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:37.374 7f2cad09dcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1116 (609.8184585571289 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1137906728, topics=[]) 03/19/2026 02:21:37.374 7f2cad09dcc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1137906728 with 0 response partitions (1 implied) 03/19/2026 02:21:37.376 7f2cad09d900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174739.236328, idle connection 289291.000000, request 304398.001432 03/19/2026 02:21:37.376 7f2cad09d900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1104 03/19/2026 02:21:37.376 7f2cad09d900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:37.376 7f2cad09d900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1104 (602.3318767547607 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=824437575, topics=[]) 03/19/2026 02:21:37.376 7f2cad09d900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 824437575 with 0 response partitions (1 implied) 03/19/2026 02:21:37.392 7f2caef1b860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 27 03/19/2026 02:21:37.392 7f2caef1b860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 03/19/2026 02:21:37.392 7f2caef1b860 [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)]) 03/19/2026 02:21:37.393 7f2caef1b860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:37.393 7f2caef1b860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=195078769, session_epoch=1107, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.393 7f2caef1b860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1113 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=195078769, session_epoch=1107, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.393 7f2caef1b860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175406.620117, idle connection 289807.000000, request 304999.943256 03/19/2026 02:21:37.393 7f2caef1b860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175406.136230, idle connection 289807.000000, request 304999.469519 03/19/2026 02:21:37.477 7f2caef3f680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175690.399658, idle connection 289372.000000, request 304394.632578 03/19/2026 02:21:37.477 7f2caef3f680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1193 03/19/2026 02:21:37.477 7f2caef3f680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:37.478 7f2caef3f680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1193 (606.0724258422852 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=828351460, topics=[]) 03/19/2026 02:21:37.478 7f2caef3f680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 828351460 with 0 response partitions (1 implied) 03/19/2026 02:21:37.478 7f2caf793d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175524.556396, idle connection 290323.000000, request 304394.148111 03/19/2026 02:21:37.478 7f2caf793ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174925.649170, idle connection 290817.000000, request 304394.695282 03/19/2026 02:21:37.478 7f2caef3f540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175391.723145, idle connection 290623.000000, request 304395.143032 03/19/2026 02:21:37.479 7f2caf793360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 142 03/19/2026 02:21:37.479 7f2caf793360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 03/19/2026 02:21:37.479 7f2caf793360 [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)]) 03/19/2026 02:21:37.479 7f2caf793360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:37.479 7f2caf793360 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=682885807, session_epoch=1133, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.479 7f2caf793360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1139 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=682885807, session_epoch=1133, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.479 7f2caf793360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175072.086914, idle connection 289116.000000, request 304999.947309 03/19/2026 02:21:37.480 7f2caef1b5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174253.075928, idle connection 289891.000000, request 304395.100117 03/19/2026 02:21:37.480 7f2caf793d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1143 03/19/2026 02:21:37.480 7f2caf793d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:37.480 7f2caf793d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1143 (607.708215713501 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2014497448, topics=[]) 03/19/2026 02:21:37.480 7f2caf793d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2014497448 with 0 response partitions (1 implied) 03/19/2026 02:21:37.480 7f2caf793ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1122 03/19/2026 02:21:37.480 7f2caf793ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:37.481 7f2caf793ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1122 (607.6169013977051 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1366366715, topics=[]) 03/19/2026 02:21:37.481 7f2caf793ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1366366715 with 0 response partitions (1 implied) 03/19/2026 02:21:37.481 7f2caef3f540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1119 03/19/2026 02:21:37.481 7f2caef3f540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:37.481 7f2caef3f540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1119 (607.6231002807617 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=384935743, topics=[]) 03/19/2026 02:21:37.481 7f2caef3f540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 384935743 with 0 response partitions (1 implied) 03/19/2026 02:21:37.482 7f2caef1b5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1120 03/19/2026 02:21:37.482 7f2caef1b5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:37.482 7f2caef1b5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1120 (607.0737838745117 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1934074637, topics=[]) 03/19/2026 02:21:37.482 7f2caef1b5e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1934074637 with 0 response partitions (1 implied) 03/19/2026 02:21:37.482 7f2caf793360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175069.181152, idle connection 289113.000000, request 304997.046471 03/19/2026 02:21:37.559 7f2caef3f860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 142 03/19/2026 02:21:37.559 7f2caef3f860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 03/19/2026 02:21:37.559 7f2caef3f860 [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)]) 03/19/2026 02:21:37.560 7f2caef3f860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:37.560 7f2caef3f860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=709173073, session_epoch=1138, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.560 7f2caef3f860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1144 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=709173073, session_epoch=1138, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.560 7f2caef3f860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175088.874756, idle connection 290935.000000, request 304999.947309 03/19/2026 02:21:37.560 7f2caef3f0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176214.154297, idle connection 291135.000000, request 304395.211458 03/19/2026 02:21:37.560 7f2cad7155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175968.235840, idle connection 289811.000000, request 304396.047831 03/19/2026 02:21:37.561 7f2caef3f860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175088.145996, idle connection 290934.000000, request 304999.229193 03/19/2026 02:21:37.561 7f2caef3f0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1134 03/19/2026 02:21:37.561 7f2caef3f0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:37.561 7f2caef3f0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1134 (605.63063621521 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=253125093, topics=[]) 03/19/2026 02:21:37.561 7f2caef3f0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 253125093 with 0 response partitions (1 implied) 03/19/2026 02:21:37.561 7f2cad7155e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1118 03/19/2026 02:21:37.561 7f2cad7155e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:37.561 7f2cad7155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1118 (605.1559448242188 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=542859706, topics=[]) 03/19/2026 02:21:37.562 7f2cad7155e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 542859706 with 0 response partitions (1 implied) 03/19/2026 02:21:37.578 7f2caf793f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176119.876221, idle connection 290827.000000, request 304398.032904 03/19/2026 02:21:37.579 7f2caf793f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1152 03/19/2026 02:21:37.579 7f2caf793f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:37.579 7f2caf793f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1152 (602.5052070617676 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1676342825, topics=[]) 03/19/2026 02:21:37.579 7f2caf793f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1676342825 with 0 response partitions (1 implied) 03/19/2026 02:21:37.597 7f2caf793680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176398.942139, idle connection 290880.000000, request 304397.998095 03/19/2026 02:21:37.597 7f2caf793680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1109 03/19/2026 02:21:37.597 7f2caf793680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:37.597 7f2caf793680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1109 (602.4973392486572 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=463264883, topics=[]) 03/19/2026 02:21:37.597 7f2caf793680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 463264883 with 0 response partitions (1 implied) 03/19/2026 02:21:37.628 7f2caf793a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174647.378174, idle connection 289664.000000, request 304398.224354 03/19/2026 02:21:37.628 7f2caf793a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1140 03/19/2026 02:21:37.628 7f2caf793a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:37.628 7f2caf793a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1140 (602.3192405700684 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1117879767, topics=[]) 03/19/2026 02:21:37.629 7f2caf793a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1117879767 with 0 response partitions (1 implied) 03/19/2026 02:21:37.669 7f2caf793040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175122.758789, idle connection 290518.000000, request 304398.957729 03/19/2026 02:21:37.669 7f2caf793040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1143 03/19/2026 02:21:37.670 7f2caf793040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:37.670 7f2caf793040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1143 (601.682186126709 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1725896610, topics=[]) 03/19/2026 02:21:37.670 7f2caf793040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1725896610 with 0 response partitions (1 implied) 03/19/2026 02:21:37.775 7f2caef3f5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174879.836914, idle connection 289517.000000, request 304398.960352 03/19/2026 02:21:37.776 7f2caef3f5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1192 03/19/2026 02:21:37.776 7f2caef3f5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:37.776 7f2caef3f5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1192 (601.7775535583496 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1088720252, topics=[]) 03/19/2026 02:21:37.776 7f2caef3f5e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1088720252 with 0 response partitions (1 implied) 03/19/2026 02:21:37.792 7f2cad715540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174479.198730, idle connection 289058.000000, request 304398.966789 03/19/2026 02:21:37.793 7f2cad715540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1106 03/19/2026 02:21:37.793 7f2cad715540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:37.793 7f2cad715540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1106 (601.7227172851562 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1560518070, topics=[]) 03/19/2026 02:21:37.793 7f2cad715540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1560518070 with 0 response partitions (1 implied) 03/19/2026 02:21:37.830 7f2cad7154a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 2 03/19/2026 02:21:37.830 7f2cad7154a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 03/19/2026 02:21:37.830 7f2cad7154a0 [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)]) 03/19/2026 02:21:37.830 7f2cad7154a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:37.830 7f2cad7154a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1615957650, session_epoch=1099, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.831 7f2cad7154a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1105 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1615957650, session_epoch=1099, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.831 7f2cad7154a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176158.278564, idle connection 289261.000000, request 304999.927998 03/19/2026 02:21:37.831 7f2caf793c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 30 03/19/2026 02:21:37.831 7f2caf793c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 03/19/2026 02:21:37.831 7f2caf793c20 [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)]) 03/19/2026 02:21:37.831 7f2caf793c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:37.831 7f2caf793c20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2052040693, session_epoch=1106, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.831 7f2caf793c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1112 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2052040693, session_epoch=1106, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.832 7f2caf793c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174955.776855, idle connection 289862.000000, request 304999.956608 03/19/2026 02:21:37.832 7f2cad09d9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 03/19/2026 02:21:37.832 7f2cad09d9a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 03/19/2026 02:21:37.832 7f2cad09d9a0 [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)]) 03/19/2026 02:21:37.832 7f2cad09d9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:37.832 7f2cad09d9a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1244083730, session_epoch=1099, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.832 7f2cad09d9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1105 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1244083730, session_epoch=1099, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.832 7f2cad09d9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174956.826660, idle connection 289438.000000, request 304999.965429 03/19/2026 02:21:37.833 7f2cad7154a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176156.406250, idle connection 289259.000000, request 304998.071432 03/19/2026 02:21:37.833 7f2caef1b7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 11 03/19/2026 02:21:37.833 7f2caef1b7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 03/19/2026 02:21:37.833 7f2caef1b7c0 [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)]) 03/19/2026 02:21:37.833 7f2caef1b7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:37.833 7f2caef1b7c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=374391613, session_epoch=1103, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.833 7f2caef1b7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1109 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=374391613, session_epoch=1103, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.833 7f2caef1b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176164.341064, idle connection 288758.000000, request 304999.964476 03/19/2026 02:21:37.834 7f2caf793c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174953.815674, idle connection 289860.000000, request 304998.001337 03/19/2026 02:21:37.834 7f2cad09d9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174955.199951, idle connection 289437.000000, request 304998.339891 03/19/2026 02:21:37.834 7f2caf793860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 55 03/19/2026 02:21:37.834 7f2caf793860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 03/19/2026 02:21:37.834 7f2caf793860 [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)]) 03/19/2026 02:21:37.834 7f2caf793860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:37.835 7f2caf793860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=179484960, session_epoch=1114, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.835 7f2caf793860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1120 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=179484960, session_epoch=1114, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.835 7f2caf793860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174961.222168, idle connection 289968.000000, request 304999.965191 03/19/2026 02:21:37.835 7f2caef1b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 176162.613037, idle connection 288757.000000, request 304998.239994 03/19/2026 02:21:37.835 7f2caf793180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174485.504883, idle connection 290258.000000, request 304396.117210 03/19/2026 02:21:37.836 7f2caf793860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174960.427002, idle connection 289967.000000, request 304999.172688 03/19/2026 02:21:37.836 7f2caf793180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1117 03/19/2026 02:21:37.836 7f2caf793180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:37.836 7f2caf793180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1117 (604.5055389404297 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1036523930, topics=[]) 03/19/2026 02:21:37.836 7f2caf793180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1036523930 with 0 response partitions (1 implied) 03/19/2026 02:21:37.851 7f2caf793540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 24 03/19/2026 02:21:37.851 7f2caf793540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 03/19/2026 02:21:37.851 7f2caf793540 [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)]) 03/19/2026 02:21:37.851 7f2caf793540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:37.851 7f2caf793540 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1607225837, session_epoch=1108, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.851 7f2caf793540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1114 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1607225837, session_epoch=1108, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.851 7f2caf793540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174949.793457, idle connection 290745.000000, request 304999.935389 03/19/2026 02:21:37.852 7f2caf793540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174949.327881, idle connection 290745.000000, request 304999.483109 03/19/2026 02:21:37.854 7f2cad09dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175684.546875, idle connection 290248.000000, request 304399.179220 03/19/2026 02:21:37.854 7f2cad09dc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1104 03/19/2026 02:21:37.854 7f2cad09dc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:37.854 7f2cad09dc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1104 (601.2027263641357 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=794221359, topics=[]) 03/19/2026 02:21:37.854 7f2cad09dc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 794221359 with 0 response partitions (1 implied) 03/19/2026 02:21:37.858 7f2caf793b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 56 03/19/2026 02:21:37.858 7f2caf793b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 03/19/2026 02:21:37.858 7f2caf793b80 [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)]) 03/19/2026 02:21:37.858 7f2caf793b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:37.858 7f2caf793b80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=900741920, session_epoch=1110, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.859 7f2caf793b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1116 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=900741920, session_epoch=1110, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.859 7f2caf793b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174943.916748, idle connection 289445.000000, request 304999.941349 03/19/2026 02:21:37.859 7f2caf793b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174943.478027, idle connection 289445.000000, request 304999.508142 03/19/2026 02:21:37.883 7f2caef3fa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174285.912354, idle connection 289308.000000, request 304398.954868 03/19/2026 02:21:37.884 7f2caef3fa40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1191 03/19/2026 02:21:37.884 7f2caef3fa40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:37.884 7f2caef3fa40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1191 (601.5625 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1543415504, topics=[]) 03/19/2026 02:21:37.884 7f2caef3fa40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1543415504 with 0 response partitions (1 implied) 03/19/2026 02:21:37.916 7f2cad09d720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174545.953369, idle connection 289156.000000, request 304398.795843 03/19/2026 02:21:37.916 7f2cad09d720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1573 03/19/2026 02:21:37.916 7f2cad09d720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:37.916 7f2cad09d720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1573 (601.7665863037109 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=65780457, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3809, last_stable_offset=3809, log_start_offset=0, aborted_transactions=NULL, records=b"\x00\x00\x00\x00\x00\x00\x0e\xe0\x00\x00\x00\xfe\x00\x00\x00\x00\x02\xfc\x0e'\x0f\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\x96\x03\x00\x00\x00\xd8\x02ObjectAnalyticsAlarmInfo:cn-jenk...")])]) 03/19/2026 02:21:37.917 7f2cad09d720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 65780457 with 1 response partitions (0 implied) 03/19/2026 02:21:37.917 7f2cad09d720 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 266 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3808 03/19/2026 02:21:37.917 7f2cad09d720 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3808 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 03/19/2026 02:21:37.917 7f2cad09d720 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 3809 (leader epoch 0) 03/19/2026 02:21:37.974 7f2cad09db80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 218 03/19/2026 02:21:37.974 7f2cad09db80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 03/19/2026 02:21:37.974 7f2cad09db80 [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)]) 03/19/2026 02:21:37.974 7f2cad09db80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:37.974 7f2cad09db80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=333243271, session_epoch=1149, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.974 7f2cad09db80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1155 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=333243271, session_epoch=1149, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.974 7f2cad09db80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175347.312744, idle connection 290006.000000, request 304999.948263 03/19/2026 02:21:37.975 7f2cad09dcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 35 03/19/2026 02:21:37.975 7f2cad09dcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 03/19/2026 02:21:37.975 7f2cad09dcc0 [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)]) 03/19/2026 02:21:37.975 7f2cad09dcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:37.975 7f2cad09dcc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1137906728, session_epoch=1111, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.975 7f2cad09dcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1117 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1137906728, session_epoch=1111, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.975 7f2cad09dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175091.301025, idle connection 290100.000000, request 304999.966860 03/19/2026 02:21:37.975 7f2cad09db80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175346.309570, idle connection 290005.000000, request 304998.955250 03/19/2026 02:21:37.976 7f2cad09dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175090.680176, idle connection 290100.000000, request 304999.348879 03/19/2026 02:21:37.977 7f2cad09d900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 03/19/2026 02:21:37.977 7f2cad09d900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 03/19/2026 02:21:37.977 7f2cad09d900 [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)]) 03/19/2026 02:21:37.977 7f2cad09d900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:37.977 7f2cad09d900 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=824437575, session_epoch=1099, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.977 7f2cad09d900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1105 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=824437575, session_epoch=1099, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:37.977 7f2cad09d900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174138.085449, idle connection 288690.000000, request 304999.968290 03/19/2026 02:21:37.977 7f2cad09d900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174137.825928, idle connection 288690.000000, request 304999.711037 03/19/2026 02:21:37.994 7f2caef1b860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174805.582275, idle connection 289206.000000, request 304398.909330 03/19/2026 02:21:37.994 7f2caef1b860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1113 03/19/2026 02:21:37.994 7f2caef1b860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:37.994 7f2caef1b860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1113 (601.5865802764893 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=195078769, topics=[]) 03/19/2026 02:21:37.995 7f2caef1b860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 195078769 with 0 response partitions (1 implied) 03/19/2026 02:21:38.018 7f2cad09d720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3809 03/19/2026 02:21:38.018 7f2cad09d720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 03/19/2026 02:21:38.018 7f2cad09d720 [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)]) 03/19/2026 02:21:38.018 7f2cad09d720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:38.018 7f2cad09d720 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=65780457, session_epoch=1568, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3809, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 03/19/2026 02:21:38.018 7f2cad09d720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1574 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=65780457, session_epoch=1568, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3809, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 03/19/2026 02:21:38.018 7f2cad09d720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174443.309082, idle connection 289053.000000, request 304999.938250 03/19/2026 02:21:38.019 7f2cad09d720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174442.805908, idle connection 289053.000000, request 304999.442816 03/19/2026 02:21:38.078 7f2caef3f680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 482 03/19/2026 02:21:38.078 7f2caef3f680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 03/19/2026 02:21:38.078 7f2caef3f680 [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)]) 03/19/2026 02:21:38.079 7f2caef3f680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:38.079 7f2caef3f680 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=828351460, session_epoch=1188, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.079 7f2caef3f680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1194 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=828351460, session_epoch=1188, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.079 7f2caef3f680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175088.364014, idle connection 288770.000000, request 304999.947786 03/19/2026 02:21:38.079 7f2caef3f680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175087.926514, idle connection 288769.000000, request 304999.519348 03/19/2026 02:21:38.080 7f2caf793d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 141 03/19/2026 02:21:38.081 7f2caf793d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 03/19/2026 02:21:38.081 7f2caf793d60 [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)]) 03/19/2026 02:21:38.081 7f2caf793d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:38.081 7f2caf793d60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2014497448, session_epoch=1138, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.081 7f2caf793d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1144 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2014497448, session_epoch=1138, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.081 7f2caf793d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174921.698486, idle connection 289720.000000, request 304999.960184 03/19/2026 02:21:38.081 7f2caf793ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 50 03/19/2026 02:21:38.081 7f2caf793ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 03/19/2026 02:21:38.081 7f2caf793ae0 [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)]) 03/19/2026 02:21:38.081 7f2caf793ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:38.081 7f2caf793ae0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1366366715, session_epoch=1117, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.081 7f2caf793ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1123 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1366366715, session_epoch=1117, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.082 7f2caf793ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174322.306885, idle connection 290213.000000, request 304999.957085 03/19/2026 02:21:38.082 7f2caf793d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174920.646729, idle connection 289719.000000, request 304998.907804 03/19/2026 02:21:38.082 7f2caef3f540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 65 03/19/2026 02:21:38.082 7f2caef3f540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 03/19/2026 02:21:38.082 7f2caef3f540 [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)]) 03/19/2026 02:21:38.082 7f2caef3f540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:38.083 7f2caef3f540 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=384935743, session_epoch=1114, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.083 7f2caef3f540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1120 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=384935743, session_epoch=1114, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.083 7f2caef3f540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174787.277344, idle connection 290018.000000, request 304999.950409 03/19/2026 02:21:38.083 7f2caef1b5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 34 03/19/2026 02:21:38.083 7f2caef1b5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 03/19/2026 02:21:38.083 7f2caef1b5e0 [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)]) 03/19/2026 02:21:38.083 7f2caef1b5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:38.083 7f2caef1b5e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1934074637, session_epoch=1115, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.084 7f2caef1b5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1121 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1934074637, session_epoch=1115, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.084 7f2caef1b5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173648.899902, idle connection 289287.000000, request 304999.951363 03/19/2026 02:21:38.084 7f2caf793ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174319.833740, idle connection 290211.000000, request 304997.484207 03/19/2026 02:21:38.084 7f2caf793360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174466.949219, idle connection 288511.000000, request 304394.812107 03/19/2026 02:21:38.085 7f2caef3f540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174785.439697, idle connection 290016.000000, request 304998.118639 03/19/2026 02:21:38.085 7f2caef1b5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173647.596436, idle connection 289286.000000, request 304998.653889 03/19/2026 02:21:38.085 7f2caf793360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1139 03/19/2026 02:21:38.085 7f2caf793360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:38.085 7f2caf793360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1139 (606.1751842498779 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=682885807, topics=[]) 03/19/2026 02:21:38.086 7f2caf793360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 682885807 with 0 response partitions (1 implied) 03/19/2026 02:21:38.162 7f2caef3f0e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-24', partition=0) at offset 84 03/19/2026 02:21:38.162 7f2caef3f0e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-24', partition=0)}, previous: {TopicPartition(topic='-uve-topic-24', partition=0)} 03/19/2026 02:21:38.162 7f2caef3f0e0 [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)]) 03/19/2026 02:21:38.162 7f2caef3f0e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:38.162 7f2caef3f0e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=253125093, session_epoch=1129, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.162 7f2caef3f0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1135 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=253125093, session_epoch=1129, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.162 7f2caef3f0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175611.885742, idle connection 290533.000000, request 304999.933243 03/19/2026 02:21:38.163 7f2cad7155e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-4', partition=0) at offset 34 03/19/2026 02:21:38.163 7f2cad7155e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-4', partition=0)}, previous: {TopicPartition(topic='-uve-topic-4', partition=0)} 03/19/2026 02:21:38.163 7f2cad7155e0 [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)]) 03/19/2026 02:21:38.163 7f2cad7155e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:38.163 7f2cad7155e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=542859706, session_epoch=1113, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.163 7f2cad7155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1119 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=542859706, session_epoch=1113, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.163 7f2cad7155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175365.350830, idle connection 289208.000000, request 304999.960661 03/19/2026 02:21:38.163 7f2caef3f860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174485.439697, idle connection 290331.000000, request 304396.522760 03/19/2026 02:21:38.164 7f2caef3f0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175610.591309, idle connection 290532.000000, request 304998.649359 03/19/2026 02:21:38.164 7f2caef3f860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1144 03/19/2026 02:21:38.164 7f2caef3f860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:38.164 7f2caef3f860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1144 (604.3224334716797 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=709173073, topics=[]) 03/19/2026 02:21:38.164 7f2caef3f860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 709173073 with 0 response partitions (1 implied) 03/19/2026 02:21:38.165 7f2cad7155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175363.821533, idle connection 289207.000000, request 304998.434067 03/19/2026 02:21:38.180 7f2caf793f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 162 03/19/2026 02:21:38.180 7f2caf793f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)} 03/19/2026 02:21:38.181 7f2caf793f40 [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)]) 03/19/2026 02:21:38.181 7f2caf793f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:38.181 7f2caf793f40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1676342825, session_epoch=1147, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.181 7f2caf793f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1153 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1676342825, session_epoch=1147, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.181 7f2caf793f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175517.035156, idle connection 290224.000000, request 304999.932051 03/19/2026 02:21:38.182 7f2caf793f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175516.360596, idle connection 290223.000000, request 304999.265671 03/19/2026 02:21:38.198 7f2caf793680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 18 03/19/2026 02:21:38.198 7f2caf793680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)} 03/19/2026 02:21:38.198 7f2caf793680 [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)]) 03/19/2026 02:21:38.198 7f2caf793680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:38.198 7f2caf793680 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=463264883, session_epoch=1104, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.199 7f2caf793680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1110 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=463264883, session_epoch=1104, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.199 7f2caf793680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175796.767578, idle connection 290278.000000, request 304999.936342 03/19/2026 02:21:38.199 7f2caf793680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175796.288574, idle connection 290278.000000, request 304999.465704 03/19/2026 02:21:38.230 7f2caf793a40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-20', partition=0) at offset 132 03/19/2026 02:21:38.230 7f2caf793a40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-20', partition=0)}, previous: {TopicPartition(topic='-uve-topic-20', partition=0)} 03/19/2026 02:21:38.230 7f2caf793a40 [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)]) 03/19/2026 02:21:38.230 7f2caf793a40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:38.230 7f2caf793a40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1117879767, session_epoch=1135, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.230 7f2caf793a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1141 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1117879767, session_epoch=1135, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.230 7f2caf793a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174044.689453, idle connection 289061.000000, request 304999.948025 03/19/2026 02:21:38.231 7f2caf793a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174044.260498, idle connection 289061.000000, request 304999.526262 03/19/2026 02:21:38.270 7f2caf793040 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 164 03/19/2026 02:21:38.271 7f2caf793040 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)} 03/19/2026 02:21:38.271 7f2caf793040 [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)]) 03/19/2026 02:21:38.271 7f2caf793040 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:38.271 7f2caf793040 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1725896610, session_epoch=1138, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.271 7f2caf793040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1144 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1725896610, session_epoch=1138, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.271 7f2caf793040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174520.663086, idle connection 289915.000000, request 304999.940634 03/19/2026 02:21:38.272 7f2caf793040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174520.226318, idle connection 289915.000000, request 304999.511719 03/19/2026 02:21:38.377 7f2caef3f5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 416 03/19/2026 02:21:38.377 7f2caef3f5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)} 03/19/2026 02:21:38.377 7f2caef3f5e0 [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)]) 03/19/2026 02:21:38.377 7f2caef3f5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:38.377 7f2caef3f5e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1088720252, session_epoch=1187, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.378 7f2caef3f5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1193 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1088720252, session_epoch=1187, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.378 7f2caef3f5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174277.276855, idle connection 288915.000000, request 304999.923706 03/19/2026 02:21:38.378 7f2caef3f5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174276.685547, idle connection 288914.000000, request 304999.345541 03/19/2026 02:21:38.394 7f2cad715540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 6 03/19/2026 02:21:38.394 7f2cad715540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)} 03/19/2026 02:21:38.394 7f2cad715540 [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)]) 03/19/2026 02:21:38.394 7f2cad715540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:38.394 7f2cad715540 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1560518070, session_epoch=1101, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.394 7f2cad715540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1107 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1560518070, session_epoch=1101, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.394 7f2cad715540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173877.051514, idle connection 288455.000000, request 304999.943495 03/19/2026 02:21:38.395 7f2cad715540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173876.420654, idle connection 288455.000000, request 304999.318123 03/19/2026 02:21:38.434 7f2cad7154a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175554.588379, idle connection 288657.000000, request 304396.244287 03/19/2026 02:21:38.435 7f2cad7154a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1105 03/19/2026 02:21:38.435 7f2cad7154a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:38.435 7f2cad7154a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1105 (604.4120788574219 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1615957650, topics=[]) 03/19/2026 02:21:38.435 7f2cad7154a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1615957650 with 0 response partitions (1 implied) 03/19/2026 02:21:38.436 7f2caf793c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174351.906738, idle connection 289259.000000, request 304396.085501 03/19/2026 02:21:38.436 7f2cad09d9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174353.409180, idle connection 288835.000000, request 304396.549463 03/19/2026 02:21:38.436 7f2caf793c20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1112 03/19/2026 02:21:38.436 7f2caf793c20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:38.436 7f2caf793c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1112 (604.3374538421631 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2052040693, topics=[]) 03/19/2026 02:21:38.436 7f2caf793c20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2052040693 with 0 response partitions (1 implied) 03/19/2026 02:21:38.436 7f2cad09d9a0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1105 03/19/2026 02:21:38.436 7f2cad09d9a0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:38.437 7f2cad09d9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1105 (604.2866706848145 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1244083730, topics=[]) 03/19/2026 02:21:38.437 7f2cad09d9a0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1244083730 with 0 response partitions (1 implied) 03/19/2026 02:21:38.437 7f2caef1b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175560.850342, idle connection 288155.000000, request 304396.475792 03/19/2026 02:21:38.437 7f2caf793180 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 72 03/19/2026 02:21:38.437 7f2caf793180 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)} 03/19/2026 02:21:38.437 7f2caf793180 [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)]) 03/19/2026 02:21:38.437 7f2caf793180 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:38.437 7f2caf793180 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1036523930, session_epoch=1112, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.437 7f2caf793180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1118 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1036523930, session_epoch=1112, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.438 7f2caf793180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173883.325439, idle connection 289656.000000, request 304999.945164 03/19/2026 02:21:38.438 7f2caf793860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174358.296387, idle connection 289365.000000, request 304397.040129 03/19/2026 02:21:38.438 7f2caef1b7c0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1109 03/19/2026 02:21:38.438 7f2caef1b7c0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:38.438 7f2caef1b7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1109 (604.7585010528564 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=374391613, topics=[]) 03/19/2026 02:21:38.438 7f2caef1b7c0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 374391613 with 0 response partitions (1 implied) 03/19/2026 02:21:38.438 7f2caf793860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1120 03/19/2026 02:21:38.438 7f2caf793860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:38.439 7f2caf793860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1120 (603.734016418457 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=179484960, topics=[]) 03/19/2026 02:21:38.439 7f2caf793860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 179484960 with 0 response partitions (1 implied) 03/19/2026 02:21:38.439 7f2caf793180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173881.822510, idle connection 289654.000000, request 304998.438120 03/19/2026 02:21:38.452 7f2caf793540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174348.833252, idle connection 290144.000000, request 304398.983717 03/19/2026 02:21:38.453 7f2caf793540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1114 03/19/2026 02:21:38.453 7f2caf793540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:38.453 7f2caf793540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1114 (601.5872955322266 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1607225837, topics=[]) 03/19/2026 02:21:38.453 7f2caf793540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1607225837 with 0 response partitions (1 implied) 03/19/2026 02:21:38.455 7f2cad09dc20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 0 03/19/2026 02:21:38.455 7f2cad09dc20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)} 03/19/2026 02:21:38.455 7f2cad09dc20 [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)]) 03/19/2026 02:21:38.455 7f2cad09dc20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:38.455 7f2cad09dc20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=794221359, session_epoch=1099, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.455 7f2cad09dc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1105 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=794221359, session_epoch=1099, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.455 7f2cad09dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175083.063965, idle connection 289646.000000, request 304999.952555 03/19/2026 02:21:38.456 7f2cad09dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175082.559082, idle connection 289646.000000, request 304999.452353 03/19/2026 02:21:38.460 7f2caf793b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174343.065186, idle connection 288844.000000, request 304399.087906 03/19/2026 02:21:38.460 7f2caf793b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1116 03/19/2026 02:21:38.460 7f2caf793b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:38.460 7f2caf793b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1116 (601.3150215148926 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=900741920, topics=[]) 03/19/2026 02:21:38.460 7f2caf793b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 900741920 with 0 response partitions (1 implied) 03/19/2026 02:21:38.484 7f2caef3fa40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-28', partition=0) at offset 372 03/19/2026 02:21:38.485 7f2caef3fa40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-28', partition=0)}, previous: {TopicPartition(topic='-uve-topic-28', partition=0)} 03/19/2026 02:21:38.485 7f2caef3fa40 [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)]) 03/19/2026 02:21:38.485 7f2caef3fa40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:38.485 7f2caef3fa40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1543415504, session_epoch=1186, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.485 7f2caef3fa40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1192 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1543415504, session_epoch=1186, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.485 7f2caef3fa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173684.092041, idle connection 288706.000000, request 304999.944448 03/19/2026 02:21:38.486 7f2caef3fa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173683.606934, idle connection 288705.000000, request 304999.469280 03/19/2026 02:21:38.576 7f2cad09db80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174745.487793, idle connection 289404.000000, request 304398.123026 03/19/2026 02:21:38.586 7f2cad09db80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1155 03/19/2026 02:21:38.587 7f2cad09db80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:38.587 7f2cad09db80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1155 (612.3242378234863 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=333243271, topics=[]) 03/19/2026 02:21:38.587 7f2cad09db80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 333243271 with 0 response partitions (1 implied) 03/19/2026 02:21:38.587 7f2cad09dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174479.010254, idle connection 289488.000000, request 304387.665510 03/19/2026 02:21:38.588 7f2cad09d900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173527.432861, idle connection 288080.000000, request 304389.313936 03/19/2026 02:21:38.588 7f2cad09dcc0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1117 03/19/2026 02:21:38.588 7f2cad09dcc0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:38.588 7f2cad09dcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1117 (613.1207942962646 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1137906728, topics=[]) 03/19/2026 02:21:38.588 7f2cad09dcc0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1137906728 with 0 response partitions (1 implied) 03/19/2026 02:21:38.589 7f2cad09d900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1105 03/19/2026 02:21:38.589 7f2cad09d900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:38.589 7f2cad09d900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1105 (611.8128299713135 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=824437575, topics=[]) 03/19/2026 02:21:38.589 7f2cad09d900 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 824437575 with 0 response partitions (1 implied) 03/19/2026 02:21:38.595 7f2caef1b860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 27 03/19/2026 02:21:38.612 7f2caef1b860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)} 03/19/2026 02:21:38.612 7f2caef1b860 [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)]) 03/19/2026 02:21:38.612 7f2caef1b860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:38.612 7f2caef1b860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=195078769, session_epoch=1108, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.612 7f2caef1b860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1114 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=195078769, session_epoch=1108, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.613 7f2caef1b860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174187.000000, idle connection 288588.000000, request 304999.908209 03/19/2026 02:21:38.613 7f2caef1b860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174186.415039, idle connection 288587.000000, request 304999.338865 03/19/2026 02:21:38.619 7f2cad09d720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173842.232178, idle connection 288452.000000, request 304398.864508 03/19/2026 02:21:38.620 7f2cad09d720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1574 03/19/2026 02:21:38.620 7f2cad09d720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:38.620 7f2cad09d720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1574 (601.747989654541 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=65780457, topics=[(topics='-uve-topic-0', partitions=[(partition=0, error_code=0, highwater_offset=3810, last_stable_offset=3810, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x0e\xe1\x00\x00\x00\xfe\x00\x00\x00\x00\x02\x9c\xf61\x11\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\x96\x03\x00\x00\x00\xd8\x02ObjectAnalyticsAlarmInfo:cn-jenk...')])]) 03/19/2026 02:21:38.620 7f2cad09d720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 65780457 with 1 response partitions (0 implied) 03/19/2026 02:21:38.621 7f2cad09d720 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 266 bytes of data for partition TopicPartition(topic='-uve-topic-0', partition=0) with offset 3809 03/19/2026 02:21:38.621 7f2cad09d720 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 3809 for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) 03/19/2026 02:21:38.621 7f2cad09d720 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-0', partition=0) to 3810 (leader epoch 0) 03/19/2026 02:21:38.682 7f2caef3f680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174485.549561, idle connection 288167.000000, request 304397.129059 03/19/2026 02:21:38.682 7f2caef3f680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1194 03/19/2026 02:21:38.682 7f2caef3f680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:38.682 7f2caef3f680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1194 (603.5628318786621 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=828351460, topics=[]) 03/19/2026 02:21:38.683 7f2caef3f680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 828351460 with 0 response partitions (1 implied) 03/19/2026 02:21:38.685 7f2caf793d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174317.176514, idle connection 289115.000000, request 304395.434380 03/19/2026 02:21:38.686 7f2caf793d60 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1144 03/19/2026 02:21:38.686 7f2caf793d60 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:38.686 7f2caf793d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1144 (605.0028800964355 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=2014497448, topics=[]) 03/19/2026 02:21:38.686 7f2caf793d60 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 2014497448 with 0 response partitions (1 implied) 03/19/2026 02:21:38.686 7f2caf793ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173717.545410, idle connection 289608.000000, request 304395.196199 03/19/2026 02:21:38.687 7f2caf793ae0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1123 03/19/2026 02:21:38.687 7f2caf793ae0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:38.687 7f2caf793ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1123 (605.1461696624756 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1366366715, topics=[]) 03/19/2026 02:21:38.687 7f2caf793ae0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1366366715 with 0 response partitions (1 implied) 03/19/2026 02:21:38.687 7f2caf793360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-18', partition=0) at offset 142 03/19/2026 02:21:38.687 7f2caf793360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-18', partition=0)}, previous: {TopicPartition(topic='-uve-topic-18', partition=0)} 03/19/2026 02:21:38.687 7f2caf793360 [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)]) 03/19/2026 02:21:38.687 7f2caf793360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:38.687 7f2caf793360 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=682885807, session_epoch=1134, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.687 7f2caf793360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1140 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=682885807, session_epoch=1134, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.688 7f2caf793360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173863.860840, idle connection 287908.000000, request 304999.951124 03/19/2026 02:21:38.688 7f2caef3f540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174182.450928, idle connection 289413.000000, request 304395.129681 03/19/2026 02:21:38.688 7f2caef1b5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173044.796387, idle connection 288683.000000, request 304395.854235 03/19/2026 02:21:38.688 7f2caef3f540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1120 03/19/2026 02:21:38.688 7f2caef3f540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:38.688 7f2caef3f540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1120 (605.2441596984863 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=384935743, topics=[]) 03/19/2026 02:21:38.688 7f2caef3f540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 384935743 with 0 response partitions (1 implied) 03/19/2026 02:21:38.688 7f2caef1b5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1121 03/19/2026 02:21:38.688 7f2caef1b5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:38.688 7f2caef1b5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1121 (604.8097610473633 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1934074637, topics=[]) 03/19/2026 02:21:38.689 7f2caef1b5e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1934074637 with 0 response partitions (1 implied) 03/19/2026 02:21:38.689 7f2caf793360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173862.358398, idle connection 287906.000000, request 304998.452663 03/19/2026 02:21:38.722 7f2cad09d720 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 3810 03/19/2026 02:21:38.722 7f2cad09d720 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)} 03/19/2026 02:21:38.722 7f2cad09d720 [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)]) 03/19/2026 02:21:38.722 7f2cad09d720 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:38.722 7f2cad09d720 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=65780457, session_epoch=1569, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3810, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 03/19/2026 02:21:38.722 7f2cad09d720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1575 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=65780457, session_epoch=1569, topics=[(topic='-uve-topic-0', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=3810, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[]) 03/19/2026 02:21:38.723 7f2cad09d720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173739.084473, idle connection 288349.000000, request 304999.921560 03/19/2026 02:21:38.723 7f2cad09d720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173738.559814, idle connection 288349.000000, request 304999.413490 03/19/2026 02:21:38.765 7f2caef3f860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 142 03/19/2026 02:21:38.765 7f2caef3f860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)} 03/19/2026 02:21:38.765 7f2caef3f860 [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)]) 03/19/2026 02:21:38.765 7f2caef3f860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:38.765 7f2caef3f860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=709173073, session_epoch=1139, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.765 7f2caef3f860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1145 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=709173073, session_epoch=1139, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:38.766 7f2caef3f860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173883.217773, idle connection 289729.000000, request 304999.926805 03/19/2026 02:21:38.766 7f2caef3f0e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175008.481201, idle connection 289930.000000, request 304396.541357 03/19/2026 02:21:38.766 7f2cad7155e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174762.562012, idle connection 288606.000000, request 304397.177219 03/19/2026 02:21:38.766 7f2caef3f860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173882.485596, idle connection 289728.000000, request 304999.204636 03/19/2026 02:21:38.767 7f2caef3f0e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1135 03/19/2026 02:21:38.767 7f2caef3f0e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:38.767 7f2caef3f0e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1135 (604.3245792388916 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=253125093, topics=[]) 03/19/2026 02:21:38.767 7f2caef3f0e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 253125093 with 0 response partitions (1 implied) 03/19/2026 02:21:38.767 7f2cad7155e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1119 03/19/2026 02:21:38.767 7f2cad7155e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:38.767 7f2cad7155e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1119 (604.0246486663818 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=542859706, topics=[]) 03/19/2026 02:21:38.767 7f2cad7155e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 542859706 with 0 response partitions (1 implied) 03/19/2026 02:21:38.782 7f2caf793f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174915.780029, idle connection 289623.000000, request 304398.678064 03/19/2026 02:21:38.783 7f2caf793f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1153 03/19/2026 02:21:38.783 7f2caf793f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:38.783 7f2caf793f40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1153 (602.1287441253662 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1676342825, topics=[]) 03/19/2026 02:21:38.783 7f2caf793f40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1676342825 with 0 response partitions (1 implied) 03/19/2026 02:21:38.800 7f2caf793680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 175195.748047, idle connection 289677.000000, request 304398.920774 03/19/2026 02:21:38.800 7f2caf793680 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1110 03/19/2026 02:21:38.800 7f2caf793680 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:38.800 7f2caf793680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1110 (601.6473770141602 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=463264883, topics=[]) 03/19/2026 02:21:38.801 7f2caf793680 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 463264883 with 0 response partitions (1 implied) 03/19/2026 02:21:38.831 7f2caf793a40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173443.712158, idle connection 288460.000000, request 304398.972034 03/19/2026 02:21:38.832 7f2caf793a40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1141 03/19/2026 02:21:38.832 7f2caf793a40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:38.832 7f2caf793a40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1141 (601.6016006469727 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1117879767, topics=[]) 03/19/2026 02:21:38.832 7f2caf793a40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1117879767 with 0 response partitions (1 implied) 03/19/2026 02:21:38.872 7f2caf793040 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173919.643311, idle connection 289314.000000, request 304398.921251 03/19/2026 02:21:38.873 7f2caf793040 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1144 03/19/2026 02:21:38.873 7f2caf793040 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:38.873 7f2caf793040 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1144 (601.6700267791748 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1725896610, topics=[]) 03/19/2026 02:21:38.873 7f2caf793040 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1725896610 with 0 response partitions (1 implied) 03/19/2026 02:21:38.979 7f2caef3f5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173676.068848, idle connection 288313.000000, request 304398.723125 03/19/2026 02:21:38.979 7f2caef3f5e0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1193 03/19/2026 02:21:38.979 7f2caef3f5e0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:38.979 7f2caef3f5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1193 (601.8126010894775 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1088720252, topics=[]) 03/19/2026 02:21:38.980 7f2caef3f5e0 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1088720252 with 0 response partitions (1 implied) 03/19/2026 02:21:38.995 7f2cad715540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173275.866455, idle connection 287854.000000, request 304398.757935 03/19/2026 02:21:38.996 7f2cad715540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1107 03/19/2026 02:21:38.996 7f2cad715540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:38.996 7f2cad715540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1107 (601.7627716064453 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1560518070, topics=[]) 03/19/2026 02:21:38.996 7f2cad715540 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1560518070 with 0 response partitions (1 implied) 03/19/2026 02:21:39.036 7f2cad7154a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-6', partition=0) at offset 2 03/19/2026 02:21:39.036 7f2cad7154a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-6', partition=0)}, previous: {TopicPartition(topic='-uve-topic-6', partition=0)} 03/19/2026 02:21:39.036 7f2cad7154a0 [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)]) 03/19/2026 02:21:39.036 7f2cad7154a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:39.036 7f2cad7154a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1615957650, session_epoch=1100, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.036 7f2cad7154a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1106 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1615957650, session_epoch=1100, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.037 7f2cad7154a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174952.482422, idle connection 288055.000000, request 304999.946117 03/19/2026 02:21:39.037 7f2caf793c20 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-17', partition=0) at offset 30 03/19/2026 02:21:39.037 7f2caf793c20 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-17', partition=0)}, previous: {TopicPartition(topic='-uve-topic-17', partition=0)} 03/19/2026 02:21:39.037 7f2caf793c20 [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)]) 03/19/2026 02:21:39.037 7f2caf793c20 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:39.037 7f2caf793c20 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2052040693, session_epoch=1107, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.037 7f2caf793c20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1113 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2052040693, session_epoch=1107, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.037 7f2caf793c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173750.091064, idle connection 288657.000000, request 304999.955416 03/19/2026 02:21:39.038 7f2cad7154a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174951.272705, idle connection 288054.000000, request 304998.745441 03/19/2026 02:21:39.038 7f2cad09d9a0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-1', partition=0) at offset 0 03/19/2026 02:21:39.038 7f2cad09d9a0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-1', partition=0)}, previous: {TopicPartition(topic='-uve-topic-1', partition=0)} 03/19/2026 02:21:39.038 7f2cad09d9a0 [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)]) 03/19/2026 02:21:39.038 7f2cad09d9a0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:39.038 7f2cad09d9a0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1244083730, session_epoch=1100, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.038 7f2cad09d9a0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1106 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1244083730, session_epoch=1100, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.038 7f2cad09d9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173750.688232, idle connection 288232.000000, request 304999.953270 03/19/2026 02:21:39.039 7f2caf793c20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173748.709229, idle connection 288655.000000, request 304998.578548 03/19/2026 02:21:39.039 7f2caef1b7c0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-9', partition=0) at offset 11 03/19/2026 02:21:39.039 7f2caef1b7c0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-9', partition=0)}, previous: {TopicPartition(topic='-uve-topic-9', partition=0)} 03/19/2026 02:21:39.039 7f2caef1b7c0 [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)]) 03/19/2026 02:21:39.039 7f2caef1b7c0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:39.039 7f2caef1b7c0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=374391613, session_epoch=1104, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.039 7f2caef1b7c0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1110 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=374391613, session_epoch=1104, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.039 7f2caef1b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174958.190430, idle connection 287552.000000, request 304999.963284 03/19/2026 02:21:39.040 7f2caf793860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-16', partition=0) at offset 55 03/19/2026 02:21:39.040 7f2caf793860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-16', partition=0)}, previous: {TopicPartition(topic='-uve-topic-16', partition=0)} 03/19/2026 02:21:39.040 7f2caf793860 [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)]) 03/19/2026 02:21:39.040 7f2caf793860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:39.040 7f2caf793860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=179484960, session_epoch=1115, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.040 7f2caf793860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1121 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=179484960, session_epoch=1115, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.040 7f2caf793860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173755.956543, idle connection 288763.000000, request 304999.967575 03/19/2026 02:21:39.040 7f2cad09d9a0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173748.762695, idle connection 288230.000000, request 304998.029470 03/19/2026 02:21:39.041 7f2caf793180 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173280.184570, idle connection 289052.000000, request 304396.810770 03/19/2026 02:21:39.041 7f2caef1b7c0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174956.711670, idle connection 287551.000000, request 304998.488188 03/19/2026 02:21:39.041 7f2caf793860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173754.805664, idle connection 288762.000000, request 304998.820543 03/19/2026 02:21:39.041 7f2caf793180 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1118 03/19/2026 02:21:39.042 7f2caf793180 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:39.042 7f2caf793180 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1118 (604.1858196258545 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1036523930, topics=[]) 03/19/2026 02:21:39.042 7f2caf793180 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1036523930 with 0 response partitions (1 implied) 03/19/2026 02:21:39.054 7f2caf793540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-13', partition=0) at offset 24 03/19/2026 02:21:39.054 7f2caf793540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-13', partition=0)}, previous: {TopicPartition(topic='-uve-topic-13', partition=0)} 03/19/2026 02:21:39.054 7f2caf793540 [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)]) 03/19/2026 02:21:39.054 7f2caf793540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:39.054 7f2caf793540 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1607225837, session_epoch=1109, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.054 7f2caf793540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1115 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1607225837, session_epoch=1109, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.055 7f2caf793540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173746.566650, idle connection 289542.000000, request 304999.918222 03/19/2026 02:21:39.055 7f2caf793540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173746.080811, idle connection 289541.000000, request 304999.430895 03/19/2026 02:21:39.056 7f2cad09dc20 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174482.157471, idle connection 289045.000000, request 304399.049282 03/19/2026 02:21:39.057 7f2cad09dc20 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1105 03/19/2026 02:21:39.057 7f2cad09dc20 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:39.057 7f2cad09dc20 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1105 (601.3712882995605 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=794221359, topics=[]) 03/19/2026 02:21:39.057 7f2cad09dc20 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 794221359 with 0 response partitions (1 implied) 03/19/2026 02:21:39.060 7f2caf793b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-19', partition=0) at offset 56 03/19/2026 02:21:39.060 7f2caf793b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-19', partition=0)}, previous: {TopicPartition(topic='-uve-topic-19', partition=0)} 03/19/2026 02:21:39.061 7f2caf793b80 [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)]) 03/19/2026 02:21:39.061 7f2caf793b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:39.061 7f2caf793b80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=900741920, session_epoch=1111, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.061 7f2caf793b80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1117 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=900741920, session_epoch=1111, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.061 7f2caf793b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173741.766357, idle connection 288243.000000, request 304999.960899 03/19/2026 02:21:39.061 7f2caf793b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173741.454346, idle connection 288243.000000, request 304999.652863 03/19/2026 02:21:39.088 7f2caef3fa40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173081.221191, idle connection 288103.000000, request 304397.078037 03/19/2026 02:21:39.088 7f2caef3fa40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1192 03/19/2026 02:21:39.088 7f2caef3fa40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:39.089 7f2caef3fa40 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1192 (603.4166812896729 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1543415504, topics=[]) 03/19/2026 02:21:39.089 7f2caef3fa40 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1543415504 with 0 response partitions (1 implied) 03/19/2026 02:21:39.189 7f2cad09db80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-2', partition=0) at offset 218 03/19/2026 02:21:39.189 7f2cad09db80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-2', partition=0)}, previous: {TopicPartition(topic='-uve-topic-2', partition=0)} 03/19/2026 02:21:39.189 7f2cad09db80 [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)]) 03/19/2026 02:21:39.189 7f2cad09db80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:39.190 7f2cad09db80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=333243271, session_epoch=1150, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.190 7f2cad09db80 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1156 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=333243271, session_epoch=1150, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.190 7f2cad09db80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174132.009521, idle connection 288791.000000, request 304999.934673 03/19/2026 02:21:39.190 7f2cad09dcc0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 35 03/19/2026 02:21:39.190 7f2cad09dcc0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)} 03/19/2026 02:21:39.190 7f2cad09dcc0 [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)]) 03/19/2026 02:21:39.190 7f2cad09dcc0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:39.190 7f2cad09dcc0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1137906728, session_epoch=1112, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.190 7f2cad09dcc0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1118 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1137906728, session_epoch=1112, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.190 7f2cad09dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173875.986328, idle connection 288885.000000, request 304999.965429 03/19/2026 02:21:39.191 7f2cad09d900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-3', partition=0) at offset 0 03/19/2026 02:21:39.191 7f2cad09d900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-3', partition=0)}, previous: {TopicPartition(topic='-uve-topic-3', partition=0)} 03/19/2026 02:21:39.191 7f2cad09d900 [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)]) 03/19/2026 02:21:39.191 7f2cad09d900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:39.191 7f2cad09d900 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=824437575, session_epoch=1100, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.191 7f2cad09d900 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1106 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=824437575, session_epoch=1100, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.191 7f2cad09d900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172923.975586, idle connection 287476.000000, request 304999.962091 03/19/2026 02:21:39.191 7f2cad09db80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 174130.294434, idle connection 288789.000000, request 304998.231888 03/19/2026 02:21:39.192 7f2cad09dcc0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173874.666016, idle connection 288884.000000, request 304998.648167 03/19/2026 02:21:39.192 7f2cad09d900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172923.026611, idle connection 287475.000000, request 304999.017477 03/19/2026 02:21:39.214 7f2caef1b860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173585.785400, idle connection 287987.000000, request 304398.704290 03/19/2026 02:21:39.214 7f2caef1b860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1114 03/19/2026 02:21:39.214 7f2caef1b860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:39.214 7f2caef1b860 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1114 (601.9985675811768 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=195078769, topics=[]) 03/19/2026 02:21:39.215 7f2caef1b860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 195078769 with 0 response partitions (1 implied) 03/19/2026 02:21:39.284 7f2caef3f680 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-27', partition=0) at offset 482 03/19/2026 02:21:39.284 7f2caef3f680 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-27', partition=0)}, previous: {TopicPartition(topic='-uve-topic-27', partition=0)} 03/19/2026 02:21:39.284 7f2caef3f680 [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)]) 03/19/2026 02:21:39.284 7f2caef3f680 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:39.284 7f2caef3f680 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=828351460, session_epoch=1189, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.285 7f2caef3f680 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1195 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=828351460, session_epoch=1189, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.285 7f2caef3f680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173882.520020, idle connection 287564.000000, request 304999.944448 03/19/2026 02:21:39.285 7f2caef3f680 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173882.084473, idle connection 287564.000000, request 304999.518394 03/19/2026 02:21:39.286 7f2caf793d60 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-23', partition=0) at offset 141 03/19/2026 02:21:39.286 7f2caf793d60 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-23', partition=0)}, previous: {TopicPartition(topic='-uve-topic-23', partition=0)} 03/19/2026 02:21:39.287 7f2caf793d60 [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)]) 03/19/2026 02:21:39.287 7f2caf793d60 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:39.287 7f2caf793d60 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2014497448, session_epoch=1139, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.287 7f2caf793d60 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1145 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=2014497448, session_epoch=1139, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.287 7f2caf793d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173715.760742, idle connection 288514.000000, request 304999.963999 03/19/2026 02:21:39.287 7f2caf793ae0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-21', partition=0) at offset 50 03/19/2026 02:21:39.287 7f2caf793ae0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-21', partition=0)}, previous: {TopicPartition(topic='-uve-topic-21', partition=0)} 03/19/2026 02:21:39.287 7f2caf793ae0 [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)]) 03/19/2026 02:21:39.287 7f2caf793ae0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:39.287 7f2caf793ae0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1366366715, session_epoch=1118, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.287 7f2caf793ae0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1124 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1366366715, session_epoch=1118, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.288 7f2caf793ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173116.394531, idle connection 289007.000000, request 304999.943972 03/19/2026 02:21:39.288 7f2caf793d60 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173714.792969, idle connection 288513.000000, request 304998.998642 03/19/2026 02:21:39.288 7f2caf793ae0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173115.780273, idle connection 289007.000000, request 304999.335527 03/19/2026 02:21:39.288 7f2caef3f540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-25', partition=0) at offset 65 03/19/2026 02:21:39.288 7f2caef3f540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-25', partition=0)}, previous: {TopicPartition(topic='-uve-topic-25', partition=0)} 03/19/2026 02:21:39.288 7f2caef3f540 [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)]) 03/19/2026 02:21:39.289 7f2caef3f540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:39.289 7f2caef3f540 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=384935743, session_epoch=1115, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.289 7f2caef3f540 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1121 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=384935743, session_epoch=1115, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.289 7f2caef3f540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173581.334717, idle connection 288812.000000, request 304999.960184 03/19/2026 02:21:39.289 7f2caef1b5e0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-7', partition=0) at offset 34 03/19/2026 02:21:39.289 7f2caef1b5e0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-7', partition=0)}, previous: {TopicPartition(topic='-uve-topic-7', partition=0)} 03/19/2026 02:21:39.289 7f2caef1b5e0 [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)]) 03/19/2026 02:21:39.289 7f2caef1b5e0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1 03/19/2026 02:21:39.289 7f2caef1b5e0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1934074637, session_epoch=1116, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.289 7f2caef1b5e0 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Request 1122 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1934074637, session_epoch=1116, topics=[], forgotten_topics_data=[]) 03/19/2026 02:21:39.290 7f2caef1b5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172443.032715, idle connection 288081.000000, request 304999.966145 03/19/2026 02:21:39.290 7f2caef3f540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173580.286621, idle connection 288811.000000, request 304998.917580 03/19/2026 02:21:39.290 7f2caf793360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173261.331055, idle connection 287305.000000, request 304397.424936 03/19/2026 02:21:39.290 7f2caef1b5e0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 172442.326660, idle connection 288080.000000, request 304999.261618 03/19/2026 02:21:39.291 7f2caf793360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1140 03/19/2026 02:21:39.291 7f2caf793360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:39.291 7f2caf793360 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1140 (603.2748222351074 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=682885807, topics=[]) 03/19/2026 02:21:39.291 7f2caf793360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 682885807 with 0 response partitions (1 implied) 03/19/2026 02:21:39.324 7f2cad09d720 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 173137.977051, idle connection 287748.000000, request 304398.823500 03/19/2026 02:21:39.324 7f2cad09d720 [kafka.protocol.parser] [DEBUG]: Received correlation id: 1575 03/19/2026 02:21:39.324 7f2cad09d720 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10 03/19/2026 02:21:39.324 7f2cad09d720 [kafka.conn] [DEBUG]: [IPv4 ('10.0.0.19', 9092)]>: Response 1575 (601.7665863037109 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=65780457, topics=[]) 03/19/2026 02:21:39.324 7f2cad09d720 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 65780457 with 0 response partitions (1 implied)