@ConfigurationProperties(prefix="spring.cloud.stream.kinesis.binder") public class KinesisBinderConfigurationProperties extends Object
Modifier and Type | Class and Description |
---|---|
static class |
KinesisBinderConfigurationProperties.Checkpoint |
static class |
KinesisBinderConfigurationProperties.Locks |
Constructor and Description |
---|
KinesisBinderConfigurationProperties() |
Modifier and Type | Method and Description |
---|---|
KinesisBinderConfigurationProperties.Checkpoint |
getCheckpoint() |
int |
getDescribeStreamBackoff() |
int |
getDescribeStreamRetries() |
String[] |
getHeaders() |
KinesisBinderConfigurationProperties.Locks |
getLocks() |
int |
getMinShardCount() |
boolean |
isAutoAddShards() |
void |
setAutoAddShards(boolean autoAddShards) |
void |
setDescribeStreamBackoff(int describeStreamBackoff) |
void |
setDescribeStreamRetries(int describeStreamRetries) |
void |
setHeaders(String... headers) |
void |
setMinShardCount(int minShardCount) |
public KinesisBinderConfigurationProperties()
public String[] getHeaders()
public void setHeaders(String... headers)
public int getDescribeStreamBackoff()
public void setDescribeStreamBackoff(int describeStreamBackoff)
public int getDescribeStreamRetries()
public void setDescribeStreamRetries(int describeStreamRetries)
public boolean isAutoAddShards()
public void setAutoAddShards(boolean autoAddShards)
public int getMinShardCount()
public void setMinShardCount(int minShardCount)
public KinesisBinderConfigurationProperties.Checkpoint getCheckpoint()
public KinesisBinderConfigurationProperties.Locks getLocks()
Copyright © 2018 Pivotal Software, Inc.. All rights reserved.