Class KinesisConfiguration

  • All Implemented Interfaces:
    Cloneable

    @UriParams
    public class KinesisConfiguration
    extends Object
    implements Cloneable
    • Constructor Detail

      • KinesisConfiguration

        public KinesisConfiguration()
    • Method Detail

      • getAmazonKinesisClient

        public com.amazonaws.services.kinesis.AmazonKinesis getAmazonKinesisClient()
      • setAmazonKinesisClient

        public void setAmazonKinesisClient​(com.amazonaws.services.kinesis.AmazonKinesis amazonKinesisClient)
      • getMaxResultsPerRequest

        public int getMaxResultsPerRequest()
      • setMaxResultsPerRequest

        public void setMaxResultsPerRequest​(int maxResultsPerRequest)
      • getStreamName

        public String getStreamName()
      • setStreamName

        public void setStreamName​(String streamName)
      • getIteratorType

        public com.amazonaws.services.kinesis.model.ShardIteratorType getIteratorType()
      • setIteratorType

        public void setIteratorType​(com.amazonaws.services.kinesis.model.ShardIteratorType iteratorType)
      • getShardId

        public String getShardId()
      • setShardId

        public void setShardId​(String shardId)
      • getSequenceNumber

        public String getSequenceNumber()
      • setSequenceNumber

        public void setSequenceNumber​(String sequenceNumber)
      • getAccessKey

        public String getAccessKey()
      • setAccessKey

        public void setAccessKey​(String accessKey)
      • getSecretKey

        public String getSecretKey()
      • setSecretKey

        public void setSecretKey​(String secretKey)
      • getRegion

        public String getRegion()
      • setRegion

        public void setRegion​(String region)
      • getProxyProtocol

        public com.amazonaws.Protocol getProxyProtocol()
      • setProxyProtocol

        public void setProxyProtocol​(com.amazonaws.Protocol proxyProtocol)
      • getProxyHost

        public String getProxyHost()
      • setProxyHost

        public void setProxyHost​(String proxyHost)
      • getProxyPort

        public Integer getProxyPort()
      • setProxyPort

        public void setProxyPort​(Integer proxyPort)
      • isAutoDiscoverClient

        public boolean isAutoDiscoverClient()
      • setAutoDiscoverClient

        public void setAutoDiscoverClient​(boolean autoDiscoverClient)