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

lmvvr0a8  于 2021-06-06  发布在  Kafka
关注(0)|答案(0)|浏览(177)

什么时候开始 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() {
    }
}

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题