我想开发一个消费者库，它可以从 spring 属性文件中读取 kinesis 流名称并创建/激活关联的消费者。
在我见过的所有示例中（例如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 库中的哪个类来一般地创建消费者。
谢谢
【问题讨论】：
标签： spring-boot spring-integration amazon-kinesis spring-cloud-stream spring-integration-aws
出于动态和运行时目的，我们建议使用 Spring Integration 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)... ;
组合。
【讨论】：
KinesisMessageDrivenChannelAdapter 可以处理多个流。见其演员。所以，如果你愿意，你真的只需要一个适配器。那么KinesisMessageDrivenChannelAdapter 的@Bean 对你来说可能就足够了吗？