spring - 使用 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 存储库中找到)。然而，这个例子on GitHub使用org.springframework.cloud:spring-cloud-starter-stream-kinesis ，仅在 1.0.0.BUILD-SNAPSHOT 下的 Spring 快照存储库中可用。 .

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

Answer 1

不清楚问题是什么。

如果你要找样本，确实没有。我们在 Spring 中拥有的解决方案绝对是 Spring Integration 的 channel 适配器。 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，而 Kinesis Binder 确实仍在开发中。