最近,我遇到了一个问题,其中一个经纪人倒闭了,卡夫卡流应用程序关闭,直到我手动重新启动它。o.a.k.s.p.i.StreamThread - Unexpected state transition from RUNNING to NOT_RUNNING如何调试此问题?至少应该抛出一个例外吗?另一个问题是,当streams线程关闭时,应用
我无法在Apache框架中运行简单的Kafka streams应用程序,运行它的就像普通的jar一样工作良好。at org.apache.kafka.streams.KafkaStreams.<init>(KafkaStreams.java:544)
at com.openet.streamer.impl.streamerImpl.activate(streamerImpl.javastreams = new KafkaStreams(topology, pr