Class KinesisProducerProperties

java.lang.Object
io.awspring.cloud.kinesis.stream.binder.properties.KinesisProducerProperties
public class KinesisProducerProperties extends Object
The Kinesis-specific producer binding configuration properties.
Since:
4.0
Author:
Peter Oates, Jacob Severson, Artem Bilan

  • Constructor Details

    • KinesisProducerProperties

      public KinesisProducerProperties()

  • Method Details

    • setSync

      public void setSync(boolean sync)

    • isSync

      public boolean isSync()

    • getSendTimeout

      public long getSendTimeout()

    • setSendTimeout

      public void setSendTimeout(long sendTimeout)

    • isEmbedHeaders

      public boolean isEmbedHeaders()

    • setEmbedHeaders

      public void setEmbedHeaders(boolean embedHeaders)

    • getRecordMetadataChannel

      public String getRecordMetadataChannel()

    • setRecordMetadataChannel

      public void setRecordMetadataChannel(String recordMetadataChannel)

    • getKplBackPressureThreshold

      public long getKplBackPressureThreshold()

    • setKplBackPressureThreshold

      public void setKplBackPressureThreshold(long kplBackPressureThreshold)