spring-boot - 根据配置创建 Kinesis 消费者

Question

我想开发一个消费者库，它将从弹簧属性文件中读取运动流名称并创建/激活关联的消费者。

在我见过的所有示例中（例如https://github.com/spring-cloud/spring-cloud-stream-samples/blob/master/kinesis-samples/kinesis-produce-consume/src/main/java/demo /stream/OrderStreamConfiguration.java），消费者是基于注释的，应该手动定义。

我想知道我可以使用 spring-integration/spring-aws-kinesis 库中的哪个类来一般地创建消费者。

谢谢

Answer 1

出于动态和运行时目的，我们建议使用 Spring Integration Java DSL 及其IntegrationFlowContext：https ://docs.spring.io/spring-integration/docs/5.0.5.RELEASE/reference/html/java-dsl.html#java- dsl 运行时流。

因此，您的意思可以通过对这些属性的迭代器和

KinesisMessageDrivenChannelAdapter kinesisMessageDrivenChannelAdapter = ...;
IntegrationFlows.from(kinesisMessageDrivenChannelAdapter)... ;

组合。