SpringCloud/spring-cloud-stream-binder-aws-kinesis
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fixes according the latest SI-AWS

Browse Source
This commit is contained in:
Artem Bilan
2018-07-02 21:03:05 -04:00
parent 925587682b
commit c992858313
2 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-cloud-stream-binder-kinesis/src/main/java/org/springframework/cloud/stream/binder/kinesis/config/KinesisBinderConfiguration.java
View File

@@ -34,7 +34,7 @@ import org.springframework.cloud.stream.binder.kinesis.provisioning.KinesisStrea
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.integration.aws.lock.DynamoDbLockRegistry;
import org.springframework.integration.aws.metadata.DynamoDbMetaDataStore;
import org.springframework.integration.aws.metadata.DynamoDbMetadataStore;
import org.springframework.integration.metadata.ConcurrentMetadataStore;
import org.springframework.integration.support.locks.LockRegistry;
@@ -121,7 +121,7 @@ public class KinesisBinderConfiguration {
public ConcurrentMetadataStore kinesisCheckpointStore(AmazonDynamoDBAsync dynamoDB) {
KinesisBinderConfigurationProperties.Checkpoint checkpoint = this.configurationProperties.getCheckpoint();
DynamoDbMetaDataStore kinesisCheckpointStore = new DynamoDbMetaDataStore(dynamoDB, checkpoint.getTable());
DynamoDbMetadataStore kinesisCheckpointStore = new DynamoDbMetadataStore(dynamoDB, checkpoint.getTable());
kinesisCheckpointStore.setReadCapacity(checkpoint.getReadCapacity());
kinesisCheckpointStore.setWriteCapacity(checkpoint.getWriteCapacity());
kinesisCheckpointStore.setCreateTableDelay(checkpoint.getCreateDelay());

4
spring-cloud-stream-binder-kinesis/src/main/java/org/springframework/cloud/stream/binder/kinesis/properties/KinesisBinderConfigurationProperties.java
View File

@@ -18,7 +18,7 @@ package org.springframework.cloud.stream.binder.kinesis.properties;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.integration.aws.lock.DynamoDbLockRegistry;
import org.springframework.integration.aws.metadata.DynamoDbMetaDataStore;
import org.springframework.integration.aws.metadata.DynamoDbMetadataStore;
/**
*
@@ -94,7 +94,7 @@ public class KinesisBinderConfigurationProperties {
public static class Checkpoint {
private String table = DynamoDbMetaDataStore.DEFAULT_TABLE_NAME;
private String table = DynamoDbMetadataStore.DEFAULT_TABLE_NAME;
private long readCapacity = 1L;