Kafka Streams：如何在异常时停止流应用程序
Kafka Streams: How to stop stream application when exception
版本 1.0
假设在低级处理器的标点方法中，创建虚拟文件失败并出现异常。遇到异常如何停止流应用？
我想知道是否有办法抛出异常，但无法在 init 方法上添加 throw 子句。以下内容需要被 try-catch 或要抛出的异常包围，并且不能使用任何一个。请提出建议。
Files.createFile(Paths.get(dummyFile));
您可以将 IOException 包装到任何未经检查的异常中，例如 RuntimeException，或者最好创建您自己的从 RuntimeException 扩展的异常并抛出它。如果您的方法对任何传入消息抛出异常，流将处于死状态，因此请停止使用消息，直到您重新启动应用程序
版本 1.0
假设在低级处理器的标点方法中，创建虚拟文件失败并出现异常。遇到异常如何停止流应用？
我想知道是否有办法抛出异常，但无法在 init 方法上添加 throw 子句。以下内容需要被 try-catch 或要抛出的异常包围，并且不能使用任何一个。请提出建议。
Files.createFile(Paths.get(dummyFile));
您可以将 IOException 包装到任何未经检查的异常中，例如 RuntimeException，或者最好创建您自己的从 RuntimeException 扩展的异常并抛出它。如果您的方法对任何传入消息抛出异常，流将处于死状态，因此请停止使用消息，直到您重新启动应用程序