Kafka Streams /如何获得迭代器正在迭代的分区？

import org.apache.kafka.streams.processor.AbstractProcessor;
import org.apache.kafka.streams.processor.ProcessorContext;
import org.apache.kafka.streams.processor.PunctuationType;
import org.apache.kafka.streams.processor.Punctuator;
import org.apache.kafka.streams.state.KeyValueIterator;
import org.apache.kafka.streams.state.KeyValueStore;

public class PartitionIteratorProcessor extends AbstractProcessor<String, String> {
    private ProcessorContext context;
    private KeyValueStore<String, String> store;

    @Override
    public void init(ProcessorContext context) {
        this.context = context;
        this.store = (KeyValueStore<String, String>) context.getStateStore("store-name");

        // 定期执行 punctuate 方法
        context.schedule(Duration.ofMillis(1000), PunctuationType.WALL_CLOCK_TIME, new Punctuator() {
            @Override
            public void punctuate(long timestamp) {
                KeyValueIterator<String, String> iterator = store.all();
                while (iterator.hasNext()) {
                    KeyValue<String, String> keyValue = iterator.next();
                    String partition = keyValue.key;
                    // 处理当前迭代的分区
                    System.out.println("正在迭代的分区：" + partition);
                }
                iterator.close();
            }
        });
    }

    @Override
    public void process(String key, String value) {
        // 处理数据记录
    }
}