public class KinesisConsumerProperties extends Object
Constructor and Description |
---|
KinesisConsumerProperties() |
Modifier and Type | Method and Description |
---|---|
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() |
void |
setCheckpointMode(org.springframework.integration.aws.inbound.kinesis.CheckpointMode checkpointMode) |
void |
setConsumerBackoff(int consumerBackoff) |
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) |
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 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 © 2019 Pivotal Software, Inc.. All rights reserved.