用Kafka Streams绑定器和函数式处理器处理Spring Cloud Streams处理异常实例
但是：我想集成异常处理，处理处理器中发生的异常，并将这些不可处理的消息发送到DLQ。我已经为反序列化错误设置了DLQ，但除了SobyChacko对类似问题的回答之外，我没有找到关于实现这一点的好建议。但这只是一个片段！有人有更详细的例子吗？我之所以问这个问题，是因为Spring Cloud Stream关于分支的文档看起来完全不同。
共有1个答案
很高兴听到你用Kafka溪流使用Spring-Cloud-Stream流。
您提到的参考文档来自一个较早的版本。请从以下页面导航到较新的文档:https://spring.io/projects/spring-cloud-stream#learn
这个问题以前也提过。看看这些对您的用例是否有帮助：
-
我对Spring批处理跳过逻辑有一些问题。我已经配置了一个作业的步骤来跳过两个异常（SQLIntegrityConstraintViolation异常和乐观锁定失败异常）： 但当作业运行时，由于我将其配置为跳过的异常，作业以未知状态完成： 我做错什么了吗？我希望这一步跳过负责抛出其中一个异常的项，并继续处理，以便以完成状态结束。
-
我使用的是Nifi 0.4.1版本。我写自定义代码转换CSV到avro格式。我已经创建了类文件，并能够生成nar文件。将nar文件放置在lib目录中，并重新启动nifi服务器。 任何帮助都很感激.. 谢谢，
-
问题内容： 这是一种常见的模式，我看到与异常关联的错误代码存储为静态最终整数。当创建要抛出的异常时，将使用这些代码之一以及错误消息来构造该异常。这导致该方法要抓住它，必须先查看代码，然后决定采取的措施。 替代方法似乎是-为每个异常错误情况声明一个类（尽管相关的异常会从通用基类中删除） 有中间立场吗？推荐的方法是什么？ 问题答案： 这是一个很好的问题。我相信绝对有中间立场。 我认为错误代码对于显示质
-
我不知道该怎么办。 当我试图从解析器获取语法错误的数量时，它显示0。 编辑： 它返回null。
-
Blade 内置了 异常处理器，在开发者模式下它会将异常输出在前端页面，并在控制台打印堆栈信息，生产环境只打印在控制台。 有些时候不满足我们的需求，这时候就需要自定义异常处理了，比如针对某个自定义的异常进行特殊处理。 我们用一个例子来解释如何操作。 定义了一个名为 TipException 的运行时异常类，用于输出错误消息到前台。 按照上面对异常的处理情况这个异常的堆栈信息会被输出在控制台，生产环
-
任何方法都可以抛出不同类型的异常。这些异常可能是需要应用程序重新部署来解决的编程错误，或者是不需要重新部署但可以解决的暂时性错误。 Hangfire可以处理所有内部的(属于Hangfire本身)和相关的外部方法(任务，过滤器等)的异常,因此不会导致整个应用程序被关闭。所有内部异常都被记录(所以不要忘记 启用日志)，最糟糕的情况是导致后台任务被暂停并延时重试 10 次。 当Hangfire遇到在执行