stacktrace=java.lang.IllegalStateException at org.apache.kafka.streams.processor.internals.ProcessorNode.lambda(SourceNode.java:96)
at org.apache.kafka.
我用的是Spring和卡夫卡流。我试图模拟一个错误场景。正如您从代码中看到的,如果我将输入值作为0传递给其中一个输入主题,我将得到一个divide by 0异常。$KStreamsTopology$1(Topology.java:28)
at org.apache.kafka.streams.kstream.internals.AbstractStream.lambdaat org.apache.kafka.streams.processor.internals.StreamTask.lambda