@ConfigurationProperties(prefix="spring.cloud.stream.kinesis.binder") public class KinesisBinderConfigurationProperties extends Object
Modifier and Type | Class and Description |
---|---|
static class |
KinesisBinderConfigurationProperties.Checkpoint
The checkpoint DynamoDB table configuration properties.
|
static class |
KinesisBinderConfigurationProperties.Locks
The locks DynamoDB table configuration properties.
|
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() |
boolean |
isAutoCreateStream() |
void |
setAutoAddShards(boolean autoAddShards) |
void |
setAutoCreateStream(boolean autoCreateStream) |
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()
public boolean isAutoCreateStream()
public void setAutoCreateStream(boolean autoCreateStream)
Copyright © 2019 Pivotal Software, Inc.. All rights reserved.