什么时候开始 process
方法在低级处理器类重写中被调用(例如。 LoadService
)? 希望在保存到状态存储时将键转换为大写,但似乎 process
方法从未被调用。
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() {
}
}
暂无答案!
目前还没有任何答案,快来回答吧!