org.apache.storm.kinesis.spout

## Class KinesisConfig

- java.lang.Object
- - org.apache.storm.kinesis.spout.KinesisConfig

- All Implemented Interfaces:
    Serializable

      public class KinesisConfig
      extends Object
      implements Serializable

  See Also:
    Serialized Form

- - ### Constructor Summary

    Constructors
    Constructor and Description
    `KinesisConfig(String streamName, com.amazonaws.services.kinesis.model.ShardIteratorType shardIteratorType, RecordToTupleMapper recordToTupleMapper, Date timestamp, FailedMessageRetryHandler failedMessageRetryHandler, ZkInfo zkInfo, KinesisConnectionInfo kinesisConnectionInfo, Long maxUncommittedRecords)`

  - ### Method Summary

    All Methods Instance Methods Concrete Methods
    Modifier and Type | Method and Description
    --- | ---
    `FailedMessageRetryHandler` | `getFailedMessageRetryHandler()`
    `KinesisConnectionInfo` | `getKinesisConnectionInfo()`
    `Long` | `getMaxUncommittedRecords()`
    `RecordToTupleMapper` | `getRecordToTupleMapper()`
    `com.amazonaws.services.kinesis.model.ShardIteratorType` | `getShardIteratorType()`
    `String` | `getStreamName()`
    `Date` | `getTimestamp()`
    `ZkInfo` | `getZkInfo()`
    `String` | `toString()`

    - ### Methods inherited from class java.lang.Object

      `clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait`

- - ### Constructor Detail

    - #### KinesisConfig

          public KinesisConfig(String streamName,
                               com.amazonaws.services.kinesis.model.ShardIteratorType shardIteratorType,
                               RecordToTupleMapper recordToTupleMapper,
                               Date timestamp,
                               FailedMessageRetryHandler failedMessageRetryHandler,
                               ZkInfo zkInfo,
                               KinesisConnectionInfo kinesisConnectionInfo,
                               Long maxUncommittedRecords)

  - ### Method Detail

    - #### getStreamName

          public String getStreamName()

    - #### getShardIteratorType

          public com.amazonaws.services.kinesis.model.ShardIteratorType getShardIteratorType()

    - #### getRecordToTupleMapper

          public RecordToTupleMapper getRecordToTupleMapper()

    - #### getTimestamp

          public Date getTimestamp()

    - #### getFailedMessageRetryHandler

          public FailedMessageRetryHandler getFailedMessageRetryHandler()

    - #### getZkInfo

          public ZkInfo getZkInfo()

    - #### getKinesisConnectionInfo

          public KinesisConnectionInfo getKinesisConnectionInfo()

    - #### getMaxUncommittedRecords

          public Long getMaxUncommittedRecords()

    - #### toString

          public String toString()

      Overrides:
        `toString` in class `Object`

Copyright © 2021 The Apache Software Foundation. All rights reserved.