时间戳

首页 > 解决方案 > Spring Cloud Stream Kinesis Binder 错误处理

spring-cloud-stream - Spring Cloud Stream Kinesis Binder 错误处理

问题描述

当 Kinesis 流使用者遇到错误并在带有 注释的方法中引发异常时@StreamListener，如何配置绑定以使消息重新排队或发送到 DLQ？我在 Spring Cloud Stream 中看到了对 Rabbit 和 Kafka 的这种级别的支持，但我没有看到 Kinesis 绑定。在 Kinesis 流处理器中处理错误的推荐方法是什么？它是如何通过配置和/或代码完成的？

标签： spring-cloud-stream

解决方案

AWS Kinesis Binder 实施完全基于 Spring Cloud Stream Core，只是重新使用其通用方法进行错误处理：https://cloud.spring.io/spring-cloud-static/spring-cloud-stream/2.2。 0.RELEASE/spring-cloud-stream.html#spring-cloud-stream-overview-error-handling

因此，您需要的只是@ServiceActivator针对特定目标错误通道的一些内容，并对失败的记录执行您需要的任何操作。

AWS Kinesis 中根本没有 DLQ/DLX/DLT 功能，因此我认为没有理由滥用它并在 Kinesis Binder 中引入一些人为的东西。

推荐阅读