在 Spring XD 中，当模块内抛出任何异常时，如何自动使 Stream 失败答案

【问题标题】：In Spring XD, How can be failing a Stream automatically when any Exceptions thrown inside Module在 Spring XD 中，当模块内抛出任何异常时，如何自动使 Stream 失败
【发布时间】：2015-12-16 20:18:57
【问题描述】：

在 Spring XD 中，我正在运行一个包含多个模块的流，如下所示

XD> Stream create MainStream --definition "Kafka-Source | processor-module1 | processor-module2| module-sink" --deploy

我在上述管道的 module2 代码中抛出 runtimeException() 并期望在抛出异常后使流失败，但 Stream 没有失败。我尝试检查流列表命令，将流状态显示为“deployed”。

如果任何一个模块中发生任何异常，谁能帮助我如何在运行时使流失败？

【问题讨论】：

标签： spring spring-xd

【解决方案1】：

不支持。

部署由管理员控制；容器不知道管理员，因此流中的模块没有内置方法来取消部署流。

您的自定义模块必须知道管理员的 URL 并使用 REST API 来取消部署流。

【讨论】：