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