使用Java和Spring的AWS动态使用者

Question

我想在Spring引导应用程序中编写一个AWS驱动流消费者。我也不确定Spring是否有对动态的支持，或者我必须使用动态客户端库。

根据这篇博客文章的说法，org.springframework.integration:spring-integration-aws拥有它(放行在maven回购中可用)。但是，这个示例论GitHub使用org.springframework.cloud:spring-cloud-starter-stream-kinesis，它只能在1.0.0.BUILD-SNAPSHOT下的Spring快照回购中使用。

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

Answer 1

不过，还不清楚问题是什么。

如果你在找一个样本，确实没有人。对，我们在Spring中的解决方案肯定是一个用于Spring集成的通道适配器。而且，KinesisMessageDrivenChannelAdapter正是AWS的使用者实现：

@SpringBootApplication
public static class MyConfiguration {

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

您在GitHub上找到的示例是针对的，并且是基于Kinesis的，它确实还在开发中。