KeyValueStore<String, Long> kvStore=(KeyValueStore<String, Long>) at org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:82)
at org.a
我有一个Kafka流应用程序,它对传入的状态进行操作,需要在编写到下一个主题之前存储状态。只应在本地存储中更新状态后才进行写入。store.put(key, state); // write back the state如何在kafka或者,使用KTable或其他概念获取和插入kafka的方法也很好。