连接-输出-0000000018不能访问StateStore KTABLE连接输出状态存储-0000000019,因为存储没有连接到处理器.);聚合函数执行这样的操作:{mappedValue1}、{mappedValue2},并且它不需要表上的联接即可工作(ProcessorNode.java:97)
at org.apache.kafka.streams.processor.internals.StreamTask.initTopolo
(KStreamMap.java:42) at org.apache.kafka.streams.processor.internals.ProcessorNode.process(ProcessorNode.java:133) at org.apache.kafka.streams.processor.internals.SourceNode.process(SourceNode.java:87) at org.apache.kafka.streams.processor.intern
我正在使用番石榴Streams.zip方法来压缩流。当集合中的流数低于8000时,它工作得很好,超过8000时,它开始抛出堆栈溢出异常。在本地调试时,我发现堆栈溢出发生在zip方法中。(Spliterators.java:681) at com.google.common.collect.Streams$1.tryAdvance(Streams.java:322) at java.util.Spliterators$1Adapter.hasNext(Spliterato