Spring cloud stream with kinesis: AmazonDynamoDBLockClient在循环中执行excpetions

文章/答案/技术大牛

发布

1回答

、

我们有一个非常简单的spring-cloud-stream应用程序，可以从AWS-Kinesis队列中读取数据。它已经工作了一段时间，没有出现任何问题。它只有很小的工作负载。(这比我们在这个应用上的用户数还要多，所以它看起来像是一个无休止的重试循环) WARN --- [s-shard-locks-1] c.a.s.d.AmazonDynamoDBLockClient :", thing) // some methods to write it to our own

浏览 15提问于2019-06-27得票数 1

1回答

Spring Cloud Stream Kinesis绑定器错误处理

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

浏览 24提问于2019-05-16得票数 1

回答已采纳

1回答

Spring包含AutoWired依赖项的类的自动配置

、、

出于概述的原因，以及Spring似乎为SQS集成提供了大量的样板免费代码，我决定将这个公共库实现为具有自动配置的自定义弹簧引导启动程序。我对Spring框架也完全陌生，因此遇到了一个问题，即我的自动配置类的实例变量没有通过AutoWired注释进行初始化。 SqsListener sqsListener; // this will be based on spring<

浏览 0提问于2020-10-28得票数 0

回答已采纳

1回答

如何暂停消费者在spring* cloud *kinesis流中消费消息

、

我正在寻找一种解决方案，当下行服务关闭时，暂停消费来自应用本身的kinesis流中的消息。我使用了spring-cloud-stream-binder-kinesis。没有明显的选择可以做到这一点。在KCL上似乎没有选项，因为well.There是在弹簧执行器绑定端点停止/暂停，这似乎不适用于Kinesis。一种选择是使用AWS SDK api，进行拉动而不是KCL/Spring云的推送机制，并在

浏览 19提问于2019-12-03得票数 2

回答已采纳

1回答

如何使用禁用KPL/KCL的CloudWatch度量

、、、、

作为参考，这里是在：中定义AWS的地方任何帮助都是非常感谢的！谢谢。

浏览 14提问于2021-12-07得票数 2

回答已采纳

1回答

如何在批处理消费模式下将Kinesis传递给函数？

、、

我正在转换现有的流处理代码，这些代码目前使用基于注释的编程模型来代替Spring函数。启用了使用者批处理模式后，如何将AWSKinsisCheck指针传递给我的Consumer，以便只有在处理器成功地处理了批处理中的所有消息之后，我才能执行手动检查点操作？ServerException(HttpStatus.INTERNAL_SERVER_ERROR, e); checkpoint(checkpointer); }在将: <

浏览 14提问于2022-07-19得票数 0