Class KinesisConsumerProperties

java.lang.Object
io.awspring.cloud.kinesis.stream.binder.properties.KinesisConsumerProperties
public class KinesisConsumerProperties extends Object
The Kinesis-specific consumer binding configuration properties.
Since:
4.0
Author:
Peter Oates, Jacob Severson, Artem Bilan, Arnaud Lecollaire, Dmytro Danilenkov, Minkyu Moon

  • Constructor Details

    • KinesisConsumerProperties

      public KinesisConsumerProperties()

  • Method Details

    • getStartTimeout

      public int getStartTimeout()

    • setStartTimeout

      public void setStartTimeout(int startTimeout)

    • getListenerMode

      public ListenerMode getListenerMode()

    • setListenerMode

      public void setListenerMode(ListenerMode listenerMode)

    • getCheckpointMode

      public CheckpointMode getCheckpointMode()

    • setCheckpointMode

      public void setCheckpointMode(CheckpointMode checkpointMode)

    • getCheckpointInterval

      public Long getCheckpointInterval()

    • setCheckpointInterval

      public void setCheckpointInterval(Long checkpointInterval)

    • getRecordsLimit

      public int getRecordsLimit()

    • setRecordsLimit

      public void setRecordsLimit(int recordsLimit)

    • getIdleBetweenPolls

      public int getIdleBetweenPolls()

    • setIdleBetweenPolls

      public void setIdleBetweenPolls(int idleBetweenPolls)

    • getConsumerBackoff

      public int getConsumerBackoff()

    • setConsumerBackoff

      public void setConsumerBackoff(int consumerBackoff)

    • getShardIteratorType

      public String getShardIteratorType()

    • setShardIteratorType

      public void setShardIteratorType(String shardIteratorType)

    • getWorkerId

      public String getWorkerId()

    • setWorkerId

      public void setWorkerId(String workerId)

    • getShardId

      public String getShardId()

    • setShardId

      public void setShardId(String shardId)

    • isEmbedHeaders

      public boolean isEmbedHeaders()

    • setEmbedHeaders

      public void setEmbedHeaders(boolean embedHeaders)

    • isFanOut

      public boolean isFanOut()

    • setFanOut

      public void setFanOut(boolean fanOut)

    • getMetricsLevel

      public software.amazon.kinesis.metrics.MetricsLevel getMetricsLevel()

    • setMetricsLevel

      public void setMetricsLevel(software.amazon.kinesis.metrics.MetricsLevel metricsLevel)

    • isEmptyRecordList

      public boolean isEmptyRecordList()

    • setEmptyRecordList

      public void setEmptyRecordList(boolean emptyRecordList)

    • getLeaseTableName

      public String getLeaseTableName()

    • setLeaseTableName

      public void setLeaseTableName(String leaseTableName)

    • getPollingMaxRecords

      public int getPollingMaxRecords()

    • setPollingMaxRecords

      public void setPollingMaxRecords(int pollingMaxRecords)

    • getPollingIdleTime

      public long getPollingIdleTime()

    • setPollingIdleTime

      public void setPollingIdleTime(long pollingIdleTime)

    • getGracefulShutdownTimeout

      public long getGracefulShutdownTimeout()

    • setGracefulShutdownTimeout

      public void setGracefulShutdownTimeout(long gracefulShutdownTimeout)

    • isDynamoDbStreams

      public boolean isDynamoDbStreams()

    • setDynamoDbStreams

      public void setDynamoDbStreams(boolean dynamoDbStreams)