Kafka流:全局状态存储低级处理器处理方法

process 方法在低级处理器类重写中被调用(例如。 LoadService )? 希望在保存到状态存储时将键转换为大写,但似乎 过程

builder.addGlobalStore(svcBuilder,
    "svcsource",
    Serdes.String().deserializer(), 
    Serdes.String().serializer(),
    "svctopic",
    "loadsvc",
    () -> new LoadService());

.

public class LoadService implements Processor<String, String> {
    public void init(ProcessorContext context) {
    }

    public void process(String key, String serviceType) {
        System.out.println(key.toUpperCase());
    }

    public void close() {
    }
}