• 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏吧

标签:amazon-kinesis

amazon-kinesis

AWS Kinesis-如何从上一个检查点恢复使用

AWS Kinesis-如何从上一个检查点恢复使用
我正在使用KCL(v2)将Kafka使用者转换为AWS Kinesis使用者。在Kafka中,偏移量用于帮助消费者跟踪其最近消费的消息。如果我的Kafka应用程序死了,它将使用偏移量重新启动时从中断处开始消耗。 但是,这在Kinesis中并不相同。我可以设置kinesisClientLibConfiguration.withInitialPositionIn……继续阅读 »

amazon-kinesis

使用Spring Boot构建的AWS Kinesis使用者的集成测试

使用Spring Boot构建的AWS Kinesis使用者的集成测试
我们正在研究使用Spring Boot开发的Micro服务,该服务使用Kinesis流中的数据对其进行处理,然后将其存储在DB中。我们有良好的JUnit Mockito测试覆盖率。现在我们需要对此进行集成测试。您能否建议一个好的框架或框架集,以用于端到端地测试整个应用程序。到目前为止,我们已经检查了柑橘和弹簧整合法,但是没有运气 解决方案如下: 通常……继续阅读 »

amazon-kinesis

Apache Flink与AWS Kinesis Analytics

Apache Flink与AWS Kinesis Analytics
实际情况 我想将Apache Flink与Kinesis Analytics结合使用。就像我没有Java和Maven的经验一样,我将尝试总结我遵循的步骤和结果。 使用IntelliJ IDEA作为IDE 毫无问题地测试此example 按照其instruction更改为AWS。问题开始于以下步骤:创建并编译Apache Flink流Java代码 问题 ……继续阅读 »

amazon-kinesis

AWS RDS到AWS ES

AWS RDS到AWS ES
要求:在插入/更新到特定表时,创建一个数据流并将其推入 flex 搜索。 思想 AWS RDS(MariaDb)—–插入/更新以说出用户表—> AWS Kinesis流-使用AWS Lambda-> AWS ES 问题如何在插入/更新到特定表时创建运动流?我可以通过AWS Lambda吗? 解决方案如下……继续阅读 »