Spring Cloud Kinesis绑定器如何处理生产者和消费者的错误-根据文档，它不工作

Question

我已经遵循下面的文档，我有一个生产者和消费者与Kinesis流工作得非常好。我想了解如何处理生产者（源）和消费者（处理器）的错误，以防任何异常发生。

根据Spring Stream错误处理文档，我尝试了以下方法：

    catch (Exception e) {
    if (e instanceof MessagingException) {
        throw (MessagingException) e;
    }
    else {
        throw new MessagingException(requestMessage,
                "Exception thrown while invoking "
                        + this.invocableHandlerMethod.getShortLogMessage(),
                e);
    }
}

我该如何处理和解决这个问题？请建议和帮助我。

文档：https://github.com/spring-cloud/spring-cloud-stream-binder-aws-kinesis/blob/master/spring-cloud-stream-binder-kinesis-docs/src/main/asciidoc/overview.adoc#error-channels

Answer 1

只是为了所有面临这个问题的人的利益。如果你错过了评论区。Deepak Chaudhary的答案对消费者来说很有效。

请查看stackoverflow.com/questions/63270755/…，如果有帮助的话。谢谢你。--迪帕克·乔德里

谢谢。迪帕克

想了解我们如何才能为制片人做到这一点。