使用 Java 和 Spring 的 AWS kinesis 消费者

Question

我想在 Spring Boot 应用程序中编写 AWS kinesis 流使用者。而且我不确定 Spring 是否具有对 kinesis 的本机支持，或者我必须使用 kinesis client library。

根据this blog post org.springframework.integration:spring-integration-aws 有它（RELEASE 在 maven repo 中可用）。但是，此示例 on GitHub 使用 org.springframework.cloud:spring-cloud-starter-stream-kinesis，它仅在 1.0.0.BUILD-SNAPSHOT 下的 Spring 快照存储库中可用。

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

Answer 1

虽然不清楚是什么问题。

如果您正在寻找样品，确实没有样品。没错，我们在 Spring 中的解决方案绝对是 Spring Integration 的 Channel Adapter。 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。