1

根据 Spring 发行说明，spring-integration-aws.1.1.0.M1不包括 DynamoDB MetaDataStore 实现。仍然有ConcurrentMetadataStore一个类是基于键值的存储，并且基于实现，我想它映射具有最新序列号读取的流。但它不使用任何数据存储来检索检查点。

我正在使用弹簧集成进行运动消耗，并且需要实施检查点。我想知道是否需要通过连接到 DynamoDB 并始终更新检查点来手动执行此操作，或者是否有另一种使用 Spring 框架的方法？

PS：我不能使用 Spring Cloud KinesisBinderConfiguration，因为我从可配置的流列表中动态使用事件。

谢谢

4

1 回答 1

0

如果您不是在谈论 Spring Cloud Stream 和 AWS Kinesis Binder 实施，那么我看不到任何阻碍您将解决方案升级到 Spring Integration AWS2.0并继续使用已经提供DynamoDbMetaDataStore的 .

或者，如果您很难迁移到 Spring 集成5.0，那么您只需考虑将实现复制/粘贴到您自己的类中并将其注入KinesisMessageDrivenChannelAdapter：https ://github.com/spring-projects/spring-集成-aws/blob/master/src/main/java/org/springframework/integration/aws/metadata/DynamoDbMetaDataStore.java

虽然它确实在1.1.0.RELEASE- 我看不出你坚持使用的理由1.1.0.M1：https ://spring.io/blog/2017/11/27/spring-integration-for-aws-1-1-ga -可用的

于 2018-06-19T20:56:49.290 回答