根据配置创建 Kinesis 消费者

Question

我想开发一个消费者库，它会从 spring 属性文件和 create/activate 相关消费者中读取运动流名称。

在我看到的所有例子中（比如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 库中的哪个 class 我可以用来创建消费者。

谢谢

Answer 1

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

所以，你的意思可以通过对这些属性的迭代器和

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

组合。