基于 KStream-to-KStream Joins are always windowed joins,我的问题是如何控制窗口的大小?在主题上保存数据的大小相同吗?有没有什么好的例子来展示开窗口的KStream- to -kStream窗口连接?在我的例子中,假设我有2个KStream,kstream1和kstream2,我希望能够加入10天的kstr
persistent()我已经创建了statestore,如上面的代码所示,并尝试插入到kvStore.put(key, value);中,org.apache.kafka.streams.processor.internals.ProcessorContextImpl.forward(ProcessorContextImpl.java:202)
at org.apache.kafka.streams.kstream.internals.ForwardingCacheFlushLi