具有 Java 和 Spring 的 AWS 运动消费者

Question

我想在 Spring 引导应用程序中编写 AWS 运动流使用者。而且我不确定 Spring 是否具有对运动的原生支持，或者我必须使用 kinesis client library.

根据 this blog post org.springframework.integration:spring-integration-aws has it (RELEASE is available in maven repo). However, this example on GitHub 使用 org.springframework.cloud:spring-cloud-starter-stream-kinesis，它仅在 1.0.0.BUILD-SNAPSHOT 下的 Spring 快照存储库中可用。

编辑：问题是，我在哪里可以找到KinesisMessageDrivenChannelAdapter的例子？

Answer 1

虽然不清楚问题是什么。

如果你要找样品的话，确实没有。没错，我们在 Spring 中的解决方案绝对是 Spring 集成的通道适配器。 KinesisMessageDrivenChannelAdapter 正是 AWS Kinesis 的消费者实现：

@SpringBootApplication
public static class MyConfiguration {

    @Bean
    public KinesisMessageDrivenChannelAdapter kinesisInboundChannelChannel(AmazonKinesis amazonKinesis) {
        KinesisMessageDrivenChannelAdapter adapter =
            new KinesisMessageDrivenChannelAdapter(amazonKinesis, "MY_STREAM");
        adapter.setOutputChannel(kinesisReceiveChannel());
        return adapter;
    }
}

您在 GitHub 上找到的示例适用于 Spring Cloud Stream，基于仍在开发中的 Kinesis Binder。