Создание потребителей Kinesis на основе конфигурации

Question

Я хотел бы разработать библиотеку потребителей, которая будет считывать имена потоков кинезиса из файла свойств Spring и создавать / активировать связанных потребителей.

Во всех примерах, которые я видел (например, https://github.com/spring-cloud/spring-cloud-stream-samples/blob/master/kinesis-samples/kinesis-produce-consume/src/main/java/demo/stream/OrderStreamConfiguration.java), потребители основаны на аннотациях, и их следует определять вручную.

Я хочу знать, какой класс из Spring-интеграции /Библиотека 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-runtime-flows.

Итак, что вы имеете в виду, можно достичь с помощью итератора для этих свойств и

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

комбинация.