public class KinesisConsumerProperties extends Object
Modifier and Type | Class and Description |
---|---|
static class |
KinesisConsumerProperties.KinesisListenerMode |
Constructor and Description |
---|
KinesisConsumerProperties() |
Modifier and Type | Method and Description |
---|---|
org.springframework.integration.aws.inbound.kinesis.CheckpointMode |
getCheckpointMode() |
int |
getConsumerBackoff() |
int |
getIdleBetweenPolls() |
KinesisConsumerProperties.KinesisListenerMode |
getListenerMode() |
int |
getRecordsLimit() |
String |
getShardIteratorType() |
int |
getStartTimeout() |
void |
setCheckpointMode(org.springframework.integration.aws.inbound.kinesis.CheckpointMode checkpointMode) |
void |
setConsumerBackoff(int consumerBackoff) |
void |
setIdleBetweenPolls(int idleBetweenPolls) |
void |
setListenerMode(KinesisConsumerProperties.KinesisListenerMode listenerMode) |
void |
setRecordsLimit(int recordsLimit) |
void |
setShardIteratorType(String shardIteratorType) |
void |
setStartTimeout(int startTimeout) |
public int getStartTimeout()
public void setStartTimeout(int startTimeout)
public KinesisConsumerProperties.KinesisListenerMode getListenerMode()
public void setListenerMode(KinesisConsumerProperties.KinesisListenerMode listenerMode)
public org.springframework.integration.aws.inbound.kinesis.CheckpointMode getCheckpointMode()
public void setCheckpointMode(org.springframework.integration.aws.inbound.kinesis.CheckpointMode checkpointMode)
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)
Copyright © 2018 Pivotal Software, Inc.. All rights reserved.