Class KinesisBinderConfigurationProperties

java.lang.Object
io.awspring.cloud.kinesis.stream.binder.properties.KinesisBinderConfigurationProperties
@ConfigurationProperties(prefix="spring.cloud.stream.kinesis.binder") public class KinesisBinderConfigurationProperties extends Object
The Kinesis Binder specific configuration properties.
Since:
4.0
Author:
Peter Oates, Artem Bilan, Jacob Severson, Sergiu Pantiru, Arnaud Lecollaire, Asiel Caballero

  • Constructor Details

    • KinesisBinderConfigurationProperties

      public KinesisBinderConfigurationProperties()

  • Method Details

    • getHeaders

      public String[] getHeaders()

    • setHeaders

      public void setHeaders(String... headers)

    • getDescribeStreamBackoff

      public int getDescribeStreamBackoff()

    • setDescribeStreamBackoff

      public void setDescribeStreamBackoff(int describeStreamBackoff)

    • getDescribeStreamRetries

      public int getDescribeStreamRetries()

    • setDescribeStreamRetries

      public void setDescribeStreamRetries(int describeStreamRetries)

    • isAutoAddShards

      public boolean isAutoAddShards()

    • setAutoAddShards

      public void setAutoAddShards(boolean autoAddShards)

    • getMinShardCount

      public int getMinShardCount()

    • setMinShardCount

      public void setMinShardCount(int minShardCount)

    • getCheckpoint

      public KinesisBinderConfigurationProperties.Checkpoint getCheckpoint()

    • getLocks

      public KinesisBinderConfigurationProperties.Locks getLocks()

    • isAutoCreateStream

      public boolean isAutoCreateStream()

    • setAutoCreateStream

      public void setAutoCreateStream(boolean autoCreateStream)

    • isKplKclEnabled

      public boolean isKplKclEnabled()

    • setKplKclEnabled

      public void setKplKclEnabled(boolean kplKclEnabled)

    • isEnableObservation

      public boolean isEnableObservation()

    • setEnableObservation

      public void setEnableObservation(boolean enableObservation)