基于Spring Boot集成RabbitMQ项目发布消息到AWS Kinesis的Spring库选型咨询

优先选择spring-integration-aws实现Kinesis数据流消息发布能力，适配你当前技术栈的成本更低，无需引入额外框架体系。

• 适配现有技术栈无侵入
  你当前项目已经基于Spring Integration核心组件+AMQP集成流实现RabbitMQ消费逻辑，spring-integration-aws是Spring Integration官方推出的AWS服务扩展组件，完全符合Spring Integration的编程模型，你无需修改现有消费、处理逻辑，仅需在集成流末尾新增Kinesis出站适配器即可完成需求，学习成本几乎为零。
• 避免不必要的依赖复杂度
  spring-cloud-stream-binder-aws-kinesis是Spring Cloud Stream体系下的绑定器实现，仅适用于基于Spring Cloud Stream开发的项目。你当前项目未使用任何Spring Cloud Stream组件，若引入该方案需要额外集成整套Spring Cloud Stream依赖，不仅会增加依赖冲突的排查成本，还需要调整现有集成流逻辑适配Spring Cloud Stream的编程模型，属于完全不必要的额外开销。
• 版本兼容性更好
  你当前使用的Spring Integration 5.5.1版本，可以直接匹配spring-integration-aws 2.5.x版本，无需调整现有核心依赖的版本号，不会影响现有业务逻辑的稳定性。
• 功能完全覆盖需求
  spring-integration-aws提供的KinesisMessageHandler已经覆盖Kinesis消息发布的全量常用能力，包括自定义分区策略、异步发送、失败重试、错误处理等，完全满足你将处理后的消息发布到Kinesis Data Stream的需求。

你可以直接在现有集成流中追加Kinesis发送逻辑，示例代码如下：

@Bean
public IntegrationFlow rabbitToKinesisFlow(ConnectionFactory rabbitConnectionFactory, AmazonKinesis amazonKinesis) {
    return IntegrationFlows.from(Amqp.inboundAdapter(rabbitConnectionFactory, "待消费的RabbitMQ队列名"))
            // 原有消息处理逻辑保持不变
            .transform(/* 现有消息转换逻辑 */)
            .filter(/* 现有消息过滤逻辑 */)
            // 新增Kinesis消息发送逻辑即可
            .handle(new KinesisMessageHandler(amazonKinesis, "目标Kinesis数据流名称"))
            .get();
}

内容的提问来源于stack exchange，提问作者LBPS