Package org.apache.storm.kafka.spout.internal

Class CommonKafkaSpoutConfig<K,V>

java.lang.Object
org.apache.storm.kafka.spout.internal.CommonKafkaSpoutConfig<K,V>
All Implemented Interfaces:
Serializable
Direct Known Subclasses:
KafkaSpoutConfig, KafkaTridentSpoutConfig
public abstract class CommonKafkaSpoutConfig<K,V> extends Object implements Serializable
See Also:

  • Field Details

    • DEFAULT_POLL_TIMEOUT_MS

      public static final long DEFAULT_POLL_TIMEOUT_MS
      See Also:

    • DEFAULT_PARTITION_REFRESH_PERIOD_MS

      public static final long DEFAULT_PARTITION_REFRESH_PERIOD_MS
      See Also:

    • DEFAULT_START_TS

      public static final long DEFAULT_START_TS
      See Also:

    • DEFAULT_FIRST_POLL_OFFSET_STRATEGY

      public static final FirstPollOffsetStrategy DEFAULT_FIRST_POLL_OFFSET_STRATEGY

    • LOG

      public static final org.slf4j.Logger LOG

  • Constructor Details

    • CommonKafkaSpoutConfig

      public CommonKafkaSpoutConfig(CommonKafkaSpoutConfig.Builder<K,V,?> builder)
      Creates a new CommonKafkaSpoutConfig using a Builder.
      Parameters:
      builder - The Builder to construct the CommonKafkaSpoutConfig from

  • Method Details

    • getKafkaProps

      public Map<String,Object> getKafkaProps()
      Gets the properties that will be passed to the KafkaConsumer.
      Returns:
      The Kafka properties map

    • getTopicFilter

      public TopicFilter getTopicFilter()

    • getTopicPartitioner

      public ManualPartitioner getTopicPartitioner()

    • getTranslator

      public RecordTranslator<K,V> getTranslator()

    • getFirstPollOffsetStrategy

      public FirstPollOffsetStrategy getFirstPollOffsetStrategy()

    • getPollTimeoutMs

      public long getPollTimeoutMs()

    • getPartitionRefreshPeriodMs

      public long getPartitionRefreshPeriodMs()

    • getStartTimeStamp

      public long getStartTimeStamp()

    • toString

      public String toString()
      Overrides:
      toString in class Object