Проверка с помощью Spring AWS Integration

Согласно примечаниям к выпуску Spring, spring-integration-aws.1.1.0.M1 не включает реализацию DynamoDB MetaDataStore. Все еще ConcurrentMetadataStore Класс, который является хранилищем, основанным на значениях ключей и основанным на реализации, я предполагаю, что он отображает потоки с последним прочитанным порядковым номером. Но он не использует хранилище данных для получения контрольных точек.

Я использую пружинную интеграцию для потребления кинезисом, и мне нужно реализовать контрольные точки. Мне интересно, если мне нужно сделать это вручную, подключившись к DynamoDB и всегда обновлять контрольные точки, или есть другой способ сделать это с помощью Spring Framework?

PS: я не могу использовать Spring Cloud KinesisBinderConfiguration, поскольку я динамически использую события из списка настраиваемых потоков.

Спасибо

Источник

1 ответ

Решение

Если вы не говорите о Spring Cloud Stream и реализации AWS Kinesis Binder, то я не вижу никаких блокировщиков для вас, чтобы вы могли обновить свое решение до Spring Integration AWS 2.0 и идти вперед с уже предоставленной DynamoDbMetaDataStore,

Или если вам так сложно перейти на Spring Integration 5.0затем вы можете просто скопировать / вставить реализацию в свой собственный класс и вставить ее в KinesisMessageDrivenChannelAdapter: https://github.com/spring-projects/spring-integration-aws/blob/master/src/main/java/org/springframework/integration/aws/metadata/DynamoDbMetaDataStore.java

Хотя это действительно доступно в 1.1.0.RELEASE - Я не вижу причин, по которым вы должны придерживаться 1.1.0.M1: https://spring.io/blog/2017/11/27/spring-integration-for-aws-1-1-ga-available

Источник
Другие вопросы по тегам