代码之家 › 专栏 › 技术社区 › sansari

与SpringAWS集成的检查点

spring-integration-aws amazon-kinesis spring-integration spring-boot

sansari · 技术社区 · 6 年前

根据弹簧发行说明, spring-integration-aws.1.1.0.M1 不包括dynamodb元数据存储实现。还有 ConcurrentMetadataStore 类,它是一个基于键值的存储,并且基于实现,我认为它映射具有最新序列号读取的流。但它不使用任何数据存储来检索检查点。

我正在使用Spring集成来使用Kinesis,需要实现检查点。我想知道我是否需要通过连接到dynamodb并总是更新检查点来手动完成这项工作,或者有其他使用Spring框架的方法来完成这项工作?

P.S:我不能使用SpringCloudKinesBinderConfiguration,因为我动态地使用可配置流列表中的事件。

谢谢你

1 回复 | 直到 6 年前

Artem Bilan 6 年前

如果您不是在谈论Spring Cloud流和AWS Kinesis Binder实现,那么我看不到任何阻止您将解决方案升级到Spring集成AWS的方法。 2.0 继续提供 DynamoDbMetaDataStore .

或者如果你很难进入弹簧集成 5.0 ,然后您只需考虑将一个实现复制/粘贴到您自己的类中,并将其注入 KinesisMessageDrivenChannelAdapter 以下内容: https://github.com/spring-projects/spring-integration-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-available

推荐文章

Suhail Gupta · 运动流中的数据丢失。这可能是什么原因?

7 年前

ShaiNe Ram · 如何从s3 bucket读取数据到Kinesis流

7 年前

Hamed Minaee · 如何在aws kinesis数据分析的cloudformation中将目标设置为lambda

7 年前

Benjamin · Amazon Kinesis流与Java流相比如何?

7 年前

JDev · AWS RDS到AWS ES

7 年前

Spider · AWS Java SDK通过一个请求获取许多Cloudwatch指标

7 年前

GihanDB · 不推荐使用AmazonKinesisClient构造函数

7 年前

SuSanD · 如何在KCL中重新排序异步发送的Kinesis事件

9 年前

Ryan Fisch · 处理Kinesis流时的AWS Lambda限制

9 年前

ecyshor · Aws arn kinsis访问多个流

9 年前