10/05/2026 06:02:26.347 7fb77e630860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 106628.815674, idle connection 45420.000000, request 304999.253511
10/05/2026 06:02:26.452 7fb7802e9360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 117366.314453, idle connection 357364.000000, request 304394.332409
10/05/2026 06:02:26.453 7fb7802e9360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9986
10/05/2026 06:02:26.453 7fb7802e9360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/05/2026 06:02:26.453 7fb7802e9360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Response 9986 (606.367826461792 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=805810421, topics=[])
10/05/2026 06:02:26.453 7fb7802e9360 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 805810421 with 0 response partitions (1 implied)
10/05/2026 06:02:26.454 7fb77eff3900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 116628.436768, idle connection 295387.000000, request 304394.159317
10/05/2026 06:02:26.454 7fb77eff3900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 10154
10/05/2026 06:02:26.454 7fb77eff3900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/05/2026 06:02:26.454 7fb77eff3900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.190:9092 <connected> [IPv4 ('10.0.0.190', 9092)]>: Response 10154 (606.3318252563477 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1314936293, topics=[])
10/05/2026 06:02:26.454 7fb77eff3900 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1314936293 with 0 response partitions (1 implied)
10/05/2026 06:02:26.524 7fb77eff3400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 556
10/05/2026 06:02:26.525 7fb77eff3400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)}
10/05/2026 06:02:26.525 7fb77eff3400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fb77f076b50> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)])
10/05/2026 06:02:26.525 7fb77eff3400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
10/05/2026 06:02:26.525 7fb77eff3400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1255442584, session_epoch=9981, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:26.534 7fb77eff3400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Request 10004 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1255442584, session_epoch=9981, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:26.534 7fb77eff3400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 117801.656494, idle connection 56327.000000, request 304999.908924
10/05/2026 06:02:26.535 7fb77eff3400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 117800.983398, idle connection 56326.000000, request 304999.264240
10/05/2026 06:02:26.690 7fb77eff3360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 188
10/05/2026 06:02:26.690 7fb77eff3360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)}
10/05/2026 06:02:26.691 7fb77eff3360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fb77ef88460> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)])
10/05/2026 06:02:26.691 7fb77eff3360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/05/2026 06:02:26.691 7fb77eff3360 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=629386733, session_epoch=9913, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:26.691 7fb77eff3360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.177:9092 <connected> [IPv4 ('10.0.0.177', 9092)]>: Request 9941 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=629386733, session_epoch=9913, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:26.691 7fb77eff3360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 114857.174072, idle connection 52445.000000, request 304999.919176
10/05/2026 06:02:26.692 7fb77eff3360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 114856.555908, idle connection 52445.000000, request 304999.325514
10/05/2026 06:02:26.794 7fb77eff3540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 696
10/05/2026 06:02:26.794 7fb77eff3540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)}
10/05/2026 06:02:26.795 7fb77eff3540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fb77f277b80> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)])
10/05/2026 06:02:26.795 7fb77eff3540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
10/05/2026 06:02:26.795 7fb77eff3540 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1029604528, session_epoch=10009, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:26.795 7fb77eff3540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.190:9092 <connected> [IPv4 ('10.0.0.190', 9092)]>: Request 10025 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1029604528, session_epoch=10009, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:26.795 7fb77eff3540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 115130.433350, idle connection 53719.000000, request 304999.935865
10/05/2026 06:02:26.796 7fb7802c3f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 117899.387207, idle connection 357897.000000, request 304395.242691
10/05/2026 06:02:26.796 7fb7802c3f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9939
10/05/2026 06:02:26.796 7fb7802c3f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/05/2026 06:02:26.796 7fb7802c3f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.190:9092 <connected> [IPv4 ('10.0.0.190', 9092)]>: Response 9939 (605.3824424743652 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=753272472, topics=[])
10/05/2026 06:02:26.797 7fb7802c3f40 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 753272472 with 0 response partitions (1 implied)
10/05/2026 06:02:26.797 7fb77eff3540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 115128.490723, idle connection 53717.000000, request 304998.003244
10/05/2026 06:02:26.862 7fb77eff3b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 4911
10/05/2026 06:02:26.862 7fb77eff3b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)}
10/05/2026 06:02:26.862 7fb77eff3b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fb77e7ed8b0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)])
10/05/2026 06:02:26.862 7fb77eff3b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/05/2026 06:02:26.862 7fb77eff3b80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1316334483, session_epoch=10528, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:26.862 7fb77eff3b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.177:9092 <connected> [IPv4 ('10.0.0.177', 9092)]>: Request 10553 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1316334483, session_epoch=10528, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:26.862 7fb77eff3b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 111068.721924, idle connection 49697.000000, request 304999.943733
10/05/2026 06:02:26.863 7fb77eff3860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 7808
10/05/2026 06:02:26.863 7fb77eff3860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)}
10/05/2026 06:02:26.863 7fb77eff3860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fb77ef55670> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)])
10/05/2026 06:02:26.863 7fb77eff3860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/05/2026 06:02:26.863 7fb77eff3860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=999612730, session_epoch=11153, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:26.863 7fb77eff3860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.177:9092 <connected> [IPv4 ('10.0.0.177', 9092)]>: Request 11168 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=999612730, session_epoch=11153, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:26.863 7fb77eff3860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 115851.247314, idle connection 54055.000000, request 304999.957800
10/05/2026 06:02:26.864 7fb77eff3b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 111067.241455, idle connection 49696.000000, request 304998.471022
10/05/2026 06:02:26.864 7fb77eff3ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 116326.726318, idle connection 356324.000000, request 304394.823551
10/05/2026 06:02:26.864 7fb77eff3860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 115849.990234, idle connection 54054.000000, request 304998.704433
10/05/2026 06:02:26.865 7fb77eff3ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 10783
10/05/2026 06:02:26.865 7fb77eff3ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/05/2026 06:02:26.865 7fb77eff3ea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Response 10783 (605.9761047363281 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=380166559, topics=[])
10/05/2026 06:02:26.865 7fb77eff3ea0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 380166559 with 0 response partitions (1 implied)
10/05/2026 06:02:26.915 7fb77efa5220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 115966.734131, idle connection 54186.000000, request 304398.878098
10/05/2026 06:02:26.916 7fb77efa5220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 10037
10/05/2026 06:02:26.916 7fb77efa5220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/05/2026 06:02:26.916 7fb77efa5220 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.177:9092 <connected> [IPv4 ('10.0.0.177', 9092)]>: Response 10037 (601.7196178436279 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=187947029, topics=[])
10/05/2026 06:02:26.916 7fb77efa5220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 187947029 with 0 response partitions (1 implied)
10/05/2026 06:02:26.955 7fb77e630860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 106021.474609, idle connection 44812.000000, request 304391.903162
10/05/2026 06:02:26.955 7fb77e630860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 15011
10/05/2026 06:02:26.955 7fb77e630860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/05/2026 06:02:26.955 7fb77e630860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Response 15011 (608.7222099304199 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=256508688, topics=[])
10/05/2026 06:02:26.956 7fb77e630860 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 256508688 with 0 response partitions (1 implied)
10/05/2026 06:02:27.055 7fb7802e9360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 423
10/05/2026 06:02:27.055 7fb7802e9360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)}
10/05/2026 06:02:27.055 7fb7802e9360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fb77f277d90> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)])
10/05/2026 06:02:27.055 7fb7802e9360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
10/05/2026 06:02:27.055 7fb7802e9360 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=805810421, session_epoch=9962, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:27.055 7fb7802e9360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Request 9987 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=805810421, session_epoch=9962, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:27.056 7fb7802e9360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 116763.064209, idle connection 356761.000000, request 304999.929428
10/05/2026 06:02:27.056 7fb77eff3900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 780
10/05/2026 06:02:27.056 7fb77eff3900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)}
10/05/2026 06:02:27.056 7fb77eff3900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fb77f67a670> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)])
10/05/2026 06:02:27.056 7fb77eff3900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
10/05/2026 06:02:27.056 7fb77eff3900 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1314936293, session_epoch=10131, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:27.056 7fb77eff3900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.190:9092 <connected> [IPv4 ('10.0.0.190', 9092)]>: Request 10155 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1314936293, session_epoch=10131, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:27.056 7fb77eff3900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 116025.807373, idle connection 294784.000000, request 304999.953270
10/05/2026 06:02:27.057 7fb7802e9360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 116761.847656, idle connection 356759.000000, request 304998.722792
10/05/2026 06:02:27.057 7fb77eff3900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 116024.963379, idle connection 294783.000000, request 304999.113321
10/05/2026 06:02:27.136 7fb77eff3400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 117199.625000, idle connection 55725.000000, request 304397.895813
10/05/2026 06:02:27.137 7fb77eff3400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 10004
10/05/2026 06:02:27.137 7fb77eff3400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/05/2026 06:02:27.137 7fb77eff3400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Response 10004 (602.7586460113525 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1255442584, topics=[])
10/05/2026 06:02:27.137 7fb77eff3400 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1255442584 with 0 response partitions (1 implied)
10/05/2026 06:02:27.293 7fb77eff3360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 114255.849365, idle connection 51844.000000, request 304398.605585
10/05/2026 06:02:27.293 7fb77eff3360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9941
10/05/2026 06:02:27.293 7fb77eff3360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/05/2026 06:02:27.293 7fb77eff3360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.177:9092 <connected> [IPv4 ('10.0.0.177', 9092)]>: Response 9941 (602.0452976226807 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=629386733, topics=[])
10/05/2026 06:02:27.294 7fb77eff3360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 629386733 with 0 response partitions (1 implied)
10/05/2026 06:02:27.397 7fb7802c3f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 231
10/05/2026 06:02:27.397 7fb7802c3f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)}
10/05/2026 06:02:27.398 7fb7802c3f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fb77f1788e0> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)])
10/05/2026 06:02:27.398 7fb7802c3f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
10/05/2026 06:02:27.398 7fb7802c3f40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=753272472, session_epoch=9919, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:27.398 7fb7802c3f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.190:9092 <connected> [IPv4 ('10.0.0.190', 9092)]>: Request 9940 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=753272472, session_epoch=9919, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:27.399 7fb7802c3f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 117296.653320, idle connection 357294.000000, request 304999.938965
10/05/2026 06:02:27.399 7fb77eff3540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 114526.919434, idle connection 53115.000000, request 304396.429539
10/05/2026 06:02:27.399 7fb7802c3f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 117295.968750, idle connection 357293.000000, request 304999.265671
10/05/2026 06:02:27.399 7fb77eff3540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 10025
10/05/2026 06:02:27.400 7fb77eff3540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/05/2026 06:02:27.400 7fb77eff3540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.190:9092 <connected> [IPv4 ('10.0.0.190', 9092)]>: Response 10025 (604.3715476989746 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1029604528, topics=[])
10/05/2026 06:02:27.400 7fb77eff3540 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1029604528 with 0 response partitions (1 implied)
10/05/2026 06:02:27.465 7fb77eff3b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 110465.804199, idle connection 49094.000000, request 304397.018671
10/05/2026 06:02:27.466 7fb77eff3b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 10553
10/05/2026 06:02:27.466 7fb77eff3b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/05/2026 06:02:27.467 7fb77eff3b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.177:9092 <connected> [IPv4 ('10.0.0.177', 9092)]>: Response 10553 (604.1395664215088 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1316334483, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=4912, last_stable_offset=4912, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x13/\x00\x00\x01\x17\x00\x00\x00\x00\x02\x9a\xfe\xcd\x8c\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\xc8\x03\x00\x00\x00\x8a\x03ObjectGeneratorInfo:cn-jenkins-d...')])])
10/05/2026 06:02:27.467 7fb77eff3b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1316334483 with 1 response partitions (0 implied)
10/05/2026 06:02:27.467 7fb77eff3b80 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 291 bytes of data for partition TopicPartition(topic='-uve-topic-26', partition=0) with offset 4911
10/05/2026 06:02:27.467 7fb77eff3b80 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4911 for assigned partition TopicPartition(topic='-uve-topic-26', partition=0)
10/05/2026 06:02:27.468 7fb77eff3b80 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-26', partition=0) to 4912 (leader epoch 0)
10/05/2026 06:02:27.468 7fb77eff3ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 8328
10/05/2026 06:02:27.468 7fb77eff3ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)}
10/05/2026 06:02:27.468 7fb77eff3ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fb77f1b8310> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)])
10/05/2026 06:02:27.468 7fb77eff3ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
10/05/2026 06:02:27.469 7fb77eff3ea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=380166559, session_epoch=10767, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:27.469 7fb77eff3ea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Request 10784 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=380166559, session_epoch=10767, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:27.469 7fb77eff3ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 115721.774414, idle connection 355719.000000, request 304999.915123
10/05/2026 06:02:27.470 7fb77eff3860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 115244.822510, idle connection 53448.000000, request 304393.526793
10/05/2026 06:02:27.470 7fb77eff3860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 11168
10/05/2026 06:02:27.470 7fb77eff3860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/05/2026 06:02:27.470 7fb77eff3860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.177:9092 <connected> [IPv4 ('10.0.0.177', 9092)]>: Response 11168 (607.166051864624 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=999612730, topics=[])
10/05/2026 06:02:27.471 7fb77eff3860 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 999612730 with 0 response partitions (1 implied)
10/05/2026 06:02:27.471 7fb77eff3ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 115719.593018, idle connection 355717.000000, request 304997.744799
10/05/2026 06:02:27.517 7fb77efa5220 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-8', partition=0) at offset 545
10/05/2026 06:02:27.517 7fb77efa5220 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-8', partition=0)}, previous: {TopicPartition(topic='-uve-topic-8', partition=0)}
10/05/2026 06:02:27.517 7fb77efa5220 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fb77f0b82e0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-8', partition=0)])
10/05/2026 06:02:27.517 7fb77efa5220 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/05/2026 06:02:27.518 7fb77efa5220 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=187947029, session_epoch=10015, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:27.518 7fb77efa5220 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.177:9092 <connected> [IPv4 ('10.0.0.177', 9092)]>: Request 10038 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=187947029, session_epoch=10015, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:27.518 7fb77efa5220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 115363.770020, idle connection 53583.000000, request 304999.933720
10/05/2026 06:02:27.519 7fb77efa5220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 115363.010742, idle connection 53582.000000, request 304999.183655
10/05/2026 06:02:27.557 7fb77e630860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-0', partition=0) at offset 19239
10/05/2026 06:02:27.557 7fb77e630860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-0', partition=0)}, previous: {TopicPartition(topic='-uve-topic-0', partition=0)}
10/05/2026 06:02:27.558 7fb77e630860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fb77f08eb80> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-0', partition=0)])
10/05/2026 06:02:27.558 7fb77e630860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
10/05/2026 06:02:27.558 7fb77e630860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=256508688, session_epoch=15003, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:27.558 7fb77e630860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Request 15012 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=256508688, session_epoch=15003, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:27.558 7fb77e630860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 105418.157959, idle connection 44209.000000, request 304999.942303
10/05/2026 06:02:27.559 7fb77e630860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 105417.700439, idle connection 44209.000000, request 304999.493122
10/05/2026 06:02:27.568 7fb77eff3b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 4912
10/05/2026 06:02:27.569 7fb77eff3b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)}
10/05/2026 06:02:27.569 7fb77eff3b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fb77ef88a00> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-26', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)])
10/05/2026 06:02:27.569 7fb77eff3b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/05/2026 06:02:27.569 7fb77eff3b80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1316334483, session_epoch=10529, topics=[(topic='-uve-topic-26', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4912, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
10/05/2026 06:02:27.569 7fb77eff3b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.177:9092 <connected> [IPv4 ('10.0.0.177', 9092)]>: Request 10554 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1316334483, session_epoch=10529, topics=[(topic='-uve-topic-26', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4912, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
10/05/2026 06:02:27.569 7fb77eff3b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 110361.951416, idle connection 48990.000000, request 304999.944448
10/05/2026 06:02:27.570 7fb77eff3b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 110360.978760, idle connection 48989.000000, request 304998.978376
10/05/2026 06:02:27.571 7fb77eff3b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 10554
10/05/2026 06:02:27.571 7fb77eff3b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/05/2026 06:02:27.571 7fb77eff3b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.177:9092 <connected> [IPv4 ('10.0.0.177', 9092)]>: Response 10554 (2.142190933227539 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1316334483, topics=[(topics='-uve-topic-26', partitions=[(partition=0, error_code=0, highwater_offset=4913, last_stable_offset=4913, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00\x130\x00\x00\x01\x17\x00\x00\x00\x00\x02\xfa\xd1\x9d;\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\xc8\x03\x00\x00\x00\x8a\x03ObjectGeneratorInfo:cn-jenkins-d...')])])
10/05/2026 06:02:27.572 7fb77eff3b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1316334483 with 1 response partitions (0 implied)
10/05/2026 06:02:27.572 7fb77eff3b80 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 291 bytes of data for partition TopicPartition(topic='-uve-topic-26', partition=0) with offset 4912
10/05/2026 06:02:27.572 7fb77eff3b80 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 4912 for assigned partition TopicPartition(topic='-uve-topic-26', partition=0)
10/05/2026 06:02:27.572 7fb77eff3b80 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-26', partition=0) to 4913 (leader epoch 0)
10/05/2026 06:02:27.659 7fb7802e9360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 116159.925781, idle connection 356158.000000, request 304396.791935
10/05/2026 06:02:27.659 7fb7802e9360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9987
10/05/2026 06:02:27.659 7fb7802e9360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/05/2026 06:02:27.659 7fb7802e9360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Response 9987 (603.8339138031006 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=805810421, topics=[])
10/05/2026 06:02:27.660 7fb7802e9360 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 805810421 with 0 response partitions (1 implied)
10/05/2026 06:02:27.660 7fb77eff3900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 115422.377197, idle connection 294181.000000, request 304396.523952
10/05/2026 06:02:27.660 7fb77eff3900 [kafka.protocol.parser] [DEBUG]: Received correlation id: 10155
10/05/2026 06:02:27.660 7fb77eff3900 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/05/2026 06:02:27.660 7fb77eff3900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.190:9092 <connected> [IPv4 ('10.0.0.190', 9092)]>: Response 10155 (603.9390563964844 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1314936293, topics=[])
10/05/2026 06:02:27.660 7fb77eff3900 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1314936293 with 0 response partitions (1 implied)
10/05/2026 06:02:27.673 7fb77eff3b80 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-26', partition=0) at offset 4913
10/05/2026 06:02:27.673 7fb77eff3b80 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-26', partition=0)}, previous: {TopicPartition(topic='-uve-topic-26', partition=0)}
10/05/2026 06:02:27.673 7fb77eff3b80 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fb77f0af100> for node 1. Added set(), altered {TopicPartition(topic='-uve-topic-26', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-26', partition=0)])
10/05/2026 06:02:27.673 7fb77eff3b80 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/05/2026 06:02:27.673 7fb77eff3b80 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1316334483, session_epoch=10530, topics=[(topic='-uve-topic-26', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4913, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
10/05/2026 06:02:27.674 7fb77eff3b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.177:9092 <connected> [IPv4 ('10.0.0.177', 9092)]>: Request 10555 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1316334483, session_epoch=10530, topics=[(topic='-uve-topic-26', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=4913, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
10/05/2026 06:02:27.674 7fb77eff3b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 110257.361816, idle connection 48886.000000, request 304999.940872
10/05/2026 06:02:27.674 7fb77eff3b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 110256.777588, idle connection 48885.000000, request 304999.363422
10/05/2026 06:02:27.738 7fb77eff3400 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-15', partition=0) at offset 556
10/05/2026 06:02:27.738 7fb77eff3400 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-15', partition=0)}, previous: {TopicPartition(topic='-uve-topic-15', partition=0)}
10/05/2026 06:02:27.738 7fb77eff3400 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fb77f252670> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-15', partition=0)])
10/05/2026 06:02:27.738 7fb77eff3400 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
10/05/2026 06:02:27.738 7fb77eff3400 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1255442584, session_epoch=9982, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:27.738 7fb77eff3400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Request 10005 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1255442584, session_epoch=9982, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:27.739 7fb77eff3400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 116597.253174, idle connection 55122.000000, request 304999.929190
10/05/2026 06:02:27.739 7fb77eff3400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 116596.726562, idle connection 55122.000000, request 304999.412298
10/05/2026 06:02:27.897 7fb77eff3360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-10', partition=0) at offset 188
10/05/2026 06:02:27.897 7fb77eff3360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-10', partition=0)}, previous: {TopicPartition(topic='-uve-topic-10', partition=0)}
10/05/2026 06:02:27.897 7fb77eff3360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fb77ee4f970> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-10', partition=0)])
10/05/2026 06:02:27.897 7fb77eff3360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/05/2026 06:02:27.898 7fb77eff3360 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=629386733, session_epoch=9914, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:27.898 7fb77eff3360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.177:9092 <connected> [IPv4 ('10.0.0.177', 9092)]>: Request 9942 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=629386733, session_epoch=9914, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:27.898 7fb77eff3360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 113650.243408, idle connection 51238.000000, request 304999.896765
10/05/2026 06:02:27.899 7fb77eff3360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 113649.444336, idle connection 51237.000000, request 304999.109507
10/05/2026 06:02:28.000 7fb77eff3540 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-12', partition=0) at offset 696
10/05/2026 06:02:28.000 7fb77eff3540 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-12', partition=0)}, previous: {TopicPartition(topic='-uve-topic-12', partition=0)}
10/05/2026 06:02:28.001 7fb77eff3540 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fb77f0cc580> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-12', partition=0)])
10/05/2026 06:02:28.001 7fb77eff3540 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
10/05/2026 06:02:28.001 7fb77eff3540 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1029604528, session_epoch=10010, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:28.001 7fb77eff3540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.190:9092 <connected> [IPv4 ('10.0.0.190', 9092)]>: Request 10026 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1029604528, session_epoch=10010, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:28.001 7fb77eff3540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 113924.623047, idle connection 52513.000000, request 304999.934435
10/05/2026 06:02:28.002 7fb7802c3f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 116693.560059, idle connection 356691.000000, request 304396.852732
10/05/2026 06:02:28.002 7fb77eff3540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 113923.725342, idle connection 52512.000000, request 304999.045134
10/05/2026 06:02:28.002 7fb7802c3f40 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9940
10/05/2026 06:02:28.002 7fb7802c3f40 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/05/2026 06:02:28.003 7fb7802c3f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.190:9092 <connected> [IPv4 ('10.0.0.190', 9092)]>: Response 9940 (604.0365695953369 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=753272472, topics=[])
10/05/2026 06:02:28.003 7fb7802c3f40 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 753272472 with 0 response partitions (1 implied)
10/05/2026 06:02:28.073 7fb77eff3860 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-22', partition=0) at offset 7808
10/05/2026 06:02:28.073 7fb77eff3860 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-22', partition=0)}, previous: {TopicPartition(topic='-uve-topic-22', partition=0)}
10/05/2026 06:02:28.073 7fb77eff3860 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fb77f13c3a0> for node 1. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-22', partition=0)])
10/05/2026 06:02:28.073 7fb77eff3860 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 1
10/05/2026 06:02:28.073 7fb77eff3860 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=999612730, session_epoch=11154, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:28.073 7fb77eff3860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.177:9092 <connected> [IPv4 ('10.0.0.177', 9092)]>: Request 11169 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=999612730, session_epoch=11154, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:28.074 7fb77eff3860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 114640.746582, idle connection 52844.000000, request 304999.919891
10/05/2026 06:02:28.074 7fb77eff3ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 115116.804688, idle connection 355114.000000, request 304394.957304
10/05/2026 06:02:28.075 7fb77eff3860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 114639.789062, idle connection 52843.000000, request 304998.973131
10/05/2026 06:02:28.075 7fb77eff3ea0 [kafka.protocol.parser] [DEBUG]: Received correlation id: 10784
10/05/2026 06:02:28.075 7fb77eff3ea0 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/05/2026 06:02:28.075 7fb77eff3ea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Response 10784 (606.0981750488281 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=380166559, topics=[(topics='-uve-topic-29', partitions=[(partition=0, error_code=0, highwater_offset=8330, last_stable_offset=8330, log_start_offset=0, aborted_transactions=NULL, records=b'\x00\x00\x00\x00\x00\x00 \x88\x00\x00\x01\x0f\x00\x00\x00\x00\x02M\xe1\x82#\x00\x00\x00\x00\x00\x00\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\xff\x00\x00\x00\x01\xb8\x03\x00\x00\x00\xfa\x02ObjectGeneratorInfo:cn-jenkins-d...')])])
10/05/2026 06:02:28.075 7fb77eff3ea0 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 380166559 with 1 response partitions (0 implied)
10/05/2026 06:02:28.076 7fb77eff3ea0 [kafka.consumer.fetcher] [DEBUG]: Preparing to read 566 bytes of data for partition TopicPartition(topic='-uve-topic-29', partition=0) with offset 8328
10/05/2026 06:02:28.076 7fb77eff3ea0 [kafka.consumer.fetcher] [DEBUG]: Returning fetched records at offset 8328 for assigned partition TopicPartition(topic='-uve-topic-29', partition=0)
10/05/2026 06:02:28.076 7fb77eff3ea0 [kafka.consumer.fetcher] [DEBUG]: Updating fetch position for assigned partition TopicPartition(topic='-uve-topic-29', partition=0) to 8330 (leader epoch 0)
10/05/2026 06:02:28.120 7fb77efa5220 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 114762.358887, idle connection 52981.000000, request 304398.518085
10/05/2026 06:02:28.120 7fb77efa5220 [kafka.protocol.parser] [DEBUG]: Received correlation id: 10038
10/05/2026 06:02:28.120 7fb77efa5220 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/05/2026 06:02:28.121 7fb77efa5220 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.177:9092 <connected> [IPv4 ('10.0.0.177', 9092)]>: Response 10038 (602.2875308990479 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=187947029, topics=[])
10/05/2026 06:02:28.121 7fb77efa5220 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 187947029 with 0 response partitions (1 implied)
10/05/2026 06:02:28.160 7fb77e630860 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 104816.105225, idle connection 43607.000000, request 304397.881985
10/05/2026 06:02:28.161 7fb77e630860 [kafka.protocol.parser] [DEBUG]: Received correlation id: 15012
10/05/2026 06:02:28.161 7fb77e630860 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/05/2026 06:02:28.161 7fb77e630860 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Response 15012 (602.8618812561035 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=256508688, topics=[])
10/05/2026 06:02:28.161 7fb77e630860 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 256508688 with 0 response partitions (1 implied)
10/05/2026 06:02:28.177 7fb77eff3ea0 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-29', partition=0) at offset 8330
10/05/2026 06:02:28.177 7fb77eff3ea0 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-29', partition=0)}, previous: {TopicPartition(topic='-uve-topic-29', partition=0)}
10/05/2026 06:02:28.177 7fb77eff3ea0 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fb77f213190> for node 2. Added set(), altered {TopicPartition(topic='-uve-topic-29', partition=0)}, removed set() out of odict_keys([TopicPartition(topic='-uve-topic-29', partition=0)])
10/05/2026 06:02:28.177 7fb77eff3ea0 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
10/05/2026 06:02:28.177 7fb77eff3ea0 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=380166559, session_epoch=10768, topics=[(topic='-uve-topic-29', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=8330, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
10/05/2026 06:02:28.178 7fb77eff3ea0 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Request 10785 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=380166559, session_epoch=10768, topics=[(topic='-uve-topic-29', partitions=[(partition=0, current_leader_epoch=-1, fetch_offset=8330, log_start_offset=-1, max_bytes=1048576)])], forgotten_topics_data=[])
10/05/2026 06:02:28.178 7fb77eff3ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 115012.940674, idle connection 355011.000000, request 304999.935865
10/05/2026 06:02:28.179 7fb77eff3ea0 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 115012.291504, idle connection 355010.000000, request 304999.292612
10/05/2026 06:02:28.262 7fb7802e9360 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-5', partition=0) at offset 423
10/05/2026 06:02:28.262 7fb7802e9360 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-5', partition=0)}, previous: {TopicPartition(topic='-uve-topic-5', partition=0)}
10/05/2026 06:02:28.262 7fb7802e9360 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fb77f0f8340> for node 2. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-5', partition=0)])
10/05/2026 06:02:28.263 7fb7802e9360 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 2
10/05/2026 06:02:28.263 7fb7802e9360 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=805810421, session_epoch=9963, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:28.263 7fb7802e9360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Request 9988 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=805810421, session_epoch=9963, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:28.263 7fb7802e9360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 115555.697266, idle connection 355553.000000, request 304999.940872
10/05/2026 06:02:28.263 7fb77eff3900 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-14', partition=0) at offset 780
10/05/2026 06:02:28.263 7fb77eff3900 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-14', partition=0)}, previous: {TopicPartition(topic='-uve-topic-14', partition=0)}
10/05/2026 06:02:28.263 7fb77eff3900 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fb77f0b8850> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-14', partition=0)])
10/05/2026 06:02:28.263 7fb77eff3900 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
10/05/2026 06:02:28.264 7fb77eff3900 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1314936293, session_epoch=10132, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:28.264 7fb77eff3900 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.190:9092 <connected> [IPv4 ('10.0.0.190', 9092)]>: Request 10156 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=1314936293, session_epoch=10132, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:28.264 7fb77eff3900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 114818.279053, idle connection 293577.000000, request 304999.937534
10/05/2026 06:02:28.267 7fb7802e9360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 115551.341553, idle connection 355549.000000, request 304995.586872
10/05/2026 06:02:28.268 7fb77eff3900 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 114814.231689, idle connection 293573.000000, request 304995.891333
10/05/2026 06:02:28.278 7fb77eff3b80 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 109653.106689, idle connection 48281.000000, request 304395.674706
10/05/2026 06:02:28.279 7fb77eff3b80 [kafka.protocol.parser] [DEBUG]: Received correlation id: 10555
10/05/2026 06:02:28.279 7fb77eff3b80 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/05/2026 06:02:28.279 7fb77eff3b80 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.177:9092 <connected> [IPv4 ('10.0.0.177', 9092)]>: Response 10555 (605.02028465271 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1316334483, topics=[])
10/05/2026 06:02:28.279 7fb77eff3b80 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 1316334483 with 0 response partitions (1 implied)
10/05/2026 06:02:28.340 7fb77eff3400 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 115996.007324, idle connection 54521.000000, request 304398.682833
10/05/2026 06:02:28.340 7fb77eff3400 [kafka.protocol.parser] [DEBUG]: Received correlation id: 10005
10/05/2026 06:02:28.340 7fb77eff3400 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/05/2026 06:02:28.341 7fb77eff3400 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=2 host=10.0.0.38:9092 <connected> [IPv4 ('10.0.0.38', 9092)]>: Response 10005 (601.9937992095947 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1255442584, topics=[])
10/05/2026 06:02:28.341 7fb77eff3400 [kafka.consumer.fetcher] [DEBUG]: Node 2 sent an incremental fetch response for session 1255442584 with 0 response partitions (1 implied)
10/05/2026 06:02:28.500 7fb77eff3360 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 113048.658447, idle connection 50637.000000, request 304398.318052
10/05/2026 06:02:28.500 7fb77eff3360 [kafka.protocol.parser] [DEBUG]: Received correlation id: 9942
10/05/2026 06:02:28.500 7fb77eff3360 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/05/2026 06:02:28.500 7fb77eff3360 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=1 host=10.0.0.177:9092 <connected> [IPv4 ('10.0.0.177', 9092)]>: Response 9942 (602.3168563842773 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=629386733, topics=[])
10/05/2026 06:02:28.501 7fb77eff3360 [kafka.consumer.fetcher] [DEBUG]: Node 1 sent an incremental fetch response for session 629386733 with 0 response partitions (1 implied)
10/05/2026 06:02:28.603 7fb7802c3f40 [kafka.consumer.fetcher] [DEBUG]: Adding fetch request for partition TopicPartition(topic='-uve-topic-11', partition=0) at offset 231
10/05/2026 06:02:28.603 7fb7802c3f40 [kafka.consumer.fetcher] [DEBUG]: Building incremental partitions from next: {TopicPartition(topic='-uve-topic-11', partition=0)}, previous: {TopicPartition(topic='-uve-topic-11', partition=0)}
10/05/2026 06:02:28.603 7fb7802c3f40 [kafka.consumer.fetcher] [DEBUG]: Built incremental fetch <kafka.consumer.fetcher.FetchMetadata object at 0x7fb77f13c310> for node 3. Added set(), altered set(), removed set() out of odict_keys([TopicPartition(topic='-uve-topic-11', partition=0)])
10/05/2026 06:02:28.604 7fb7802c3f40 [kafka.consumer.fetcher] [DEBUG]: Sending FetchRequest to node 3
10/05/2026 06:02:28.604 7fb7802c3f40 [kafka.protocol.parser] [DEBUG]: Sending request FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=753272472, session_epoch=9920, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:28.604 7fb7802c3f40 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.190:9092 <connected> [IPv4 ('10.0.0.190', 9092)]>: Request 9941 (timeout_ms 305000): FetchRequest_v10(replica_id=-1, max_wait_time=500, min_bytes=1, max_bytes=52428800, isolation_level=0, session_id=753272472, session_epoch=9920, topics=[], forgotten_topics_data=[])
10/05/2026 06:02:28.604 7fb7802c3f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 116091.099121, idle connection 356089.000000, request 304999.922276
10/05/2026 06:02:28.604 7fb77eff3540 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 113321.387451, idle connection 51909.000000, request 304396.707535
10/05/2026 06:02:28.605 7fb7802c3f40 [kafka.client] [DEBUG]: Timeouts: user 0.000000, metadata 116090.423828, idle connection 356088.000000, request 304999.257326
10/05/2026 06:02:28.605 7fb77eff3540 [kafka.protocol.parser] [DEBUG]: Received correlation id: 10026
10/05/2026 06:02:28.605 7fb77eff3540 [kafka.protocol.parser] [DEBUG]: Processing response FetchResponse_v10
10/05/2026 06:02:28.605 7fb77eff3540 [kafka.conn] [DEBUG]: <BrokerConnection client_id=kafka-python-2.1.6, node_id=3 host=10.0.0.190:9092 <connected> [IPv4 ('10.0.0.190', 9092)]>: Response 10026 (604.295015335083 ms): FetchResponse_v10(throttle_time_ms=0, error_code=0, session_id=1029604528, topics=[])
10/05/2026 06:02:28.606 7fb77eff3540 [kafka.consumer.fetcher] [DEBUG]: Node 3 sent an incremental fetch response for session 1029604528 with 0 response partitions (1 implied)