public class KinesisConsumerProperties extends Object
Constructor and Description |
---|
KinesisConsumerProperties() |
Modifier and Type | Method and Description |
---|---|
Long |
getCheckpointInterval() |
org.springframework.integration.aws.inbound.kinesis.CheckpointMode |
getCheckpointMode() |
int |
getConsumerBackoff() |
int |
getIdleBetweenPolls() |
org.springframework.integration.aws.inbound.kinesis.ListenerMode |
getListenerMode() |
int |
getRecordsLimit() |
String |
getShardIteratorType() |
int |
getStartTimeout() |
String |
getWorkerId() |
boolean |
isDynamoDbStreams() |
void |
setCheckpointInterval(Long checkpointInterval) |
void |
setCheckpointMode(org.springframework.integration.aws.inbound.kinesis.CheckpointMode checkpointMode) |
void |
setConsumerBackoff(int consumerBackoff) |
void |
setDynamoDbStreams(boolean dynamoDbStreams) |
void |
setIdleBetweenPolls(int idleBetweenPolls) |
void |
setListenerMode(org.springframework.integration.aws.inbound.kinesis.ListenerMode listenerMode) |
void |
setRecordsLimit(int recordsLimit) |
void |
setShardIteratorType(String shardIteratorType) |
void |
setStartTimeout(int startTimeout) |
void |
setWorkerId(String workerId) |
public int getStartTimeout()
public void setStartTimeout(int startTimeout)
public org.springframework.integration.aws.inbound.kinesis.ListenerMode getListenerMode()
public void setListenerMode(org.springframework.integration.aws.inbound.kinesis.ListenerMode listenerMode)
public org.springframework.integration.aws.inbound.kinesis.CheckpointMode getCheckpointMode()
public void setCheckpointMode(org.springframework.integration.aws.inbound.kinesis.CheckpointMode checkpointMode)
public Long getCheckpointInterval()
public void setCheckpointInterval(Long checkpointInterval)
public int getRecordsLimit()
public void setRecordsLimit(int recordsLimit)
public int getIdleBetweenPolls()
public void setIdleBetweenPolls(int idleBetweenPolls)
public int getConsumerBackoff()
public void setConsumerBackoff(int consumerBackoff)
public String getShardIteratorType()
public void setShardIteratorType(String shardIteratorType)
public String getWorkerId()
public void setWorkerId(String workerId)
public boolean isDynamoDbStreams()
public void setDynamoDbStreams(boolean dynamoDbStreams)
Copyright © 2020 Pivotal Software, Inc.. All rights reserved.