我有一个Kafka流应用程序,它对传入的状态进行操作,需要在编写到下一个主题之前存储状态。只应在本地存储中更新状态后才进行写入。store.put(key, state); // write back the state如何在kafka或者,使用KTable或其他概念获取和插入kafka的方法也很好。
(StreamsMetricsImpl.java:208) at org.apache.kafka.streams.processor.internals.AssignedTasks.punctuate(AssignedTasks.java:430)
at org.apache.kafka.streams.processor.internals.TaskManage
我正在尝试编写我的第一个练习应用程序,使用Kafka Streams来计算主题中的字数。但是,我想我指的是旧的API,因为在lambda函数的末尾,我想将KTable的输出放到一个主题中,但我没有看到任何这样的方法。 我引用的代码使用了to()方法,但我认为现在没有这样的方法。Serdes.Short().getClass());
//1- Stream from K