我已经成功地让流应用程序使用、转换和生成数据，但我注意到流处理器会周期性地转换到ERROR状态并且进程将坐在那里不退出。向我显示如下日志:所有流线程都已死亡。该实例将处于错误状态，应关闭。有没有办法告诉Streams应用程序在达到ERROR状态后退出？也许是某种监视器线程？我看到references在KafkaStreams代码的注释中，用户需要在应用程序达到此状态后关闭应用程序，但是，我无法在文档中找到提及此任务的信息。是否有一种简单的方法来执行此关闭步骤？关闭错误的可能不正确的方法我的意图是在KafkaStreams对象上设置UncaughtExceptionHandler方法，以

我正在使用Kafka根据事件采购实现架构。假设我以JSON格式存储事件：{"name":"ProductAdded","productId":"1",quantity=3,dateAdded="2017-04-04"}我想实现一个查询，以在特定日期获得productid=x的产品数量。您可以通过SpringKafkaKstreams显示此查询的大致实现吗？更新：我使用SpringKafkaKStreams对此有所提高，但是我遇到了一个绝对的错误。这是我的春季云流卡夫卡制作人:publicinterfaceProductProducer{finalStringOUTPUT="productsOu