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
- See Also:
- 
Nested Class SummaryNested ClassesModifier and TypeClassDescriptionstatic classCommonKafkaSpoutConfig.Builder<K,V, T extends CommonKafkaSpoutConfig.Builder<K, V, T>> 
- 
Field SummaryFieldsModifier and TypeFieldDescriptionstatic final FirstPollOffsetStrategystatic final longstatic final longstatic final longstatic final org.slf4j.Logger
- 
Constructor SummaryConstructorsConstructorDescriptionCommonKafkaSpoutConfig(CommonKafkaSpoutConfig.Builder<K, V, ?> builder) Creates a new CommonKafkaSpoutConfig using a Builder.
- 
Method SummaryModifier and TypeMethodDescriptionGets the properties that will be passed to the KafkaConsumer.longlonglongtoString()
- 
Field Details- 
DEFAULT_POLL_TIMEOUT_MSpublic static final long DEFAULT_POLL_TIMEOUT_MS- See Also:
 
- 
DEFAULT_PARTITION_REFRESH_PERIOD_MSpublic static final long DEFAULT_PARTITION_REFRESH_PERIOD_MS- See Also:
 
- 
DEFAULT_START_TSpublic static final long DEFAULT_START_TS- See Also:
 
- 
DEFAULT_FIRST_POLL_OFFSET_STRATEGY
- 
LOGpublic static final org.slf4j.Logger LOG
 
- 
- 
Constructor Details- 
CommonKafkaSpoutConfigCreates a new CommonKafkaSpoutConfig using a Builder.- Parameters:
- builder- The Builder to construct the CommonKafkaSpoutConfig from
 
 
- 
- 
Method Details- 
getKafkaPropsGets the properties that will be passed to the KafkaConsumer.- Returns:
- The Kafka properties map
 
- 
getTopicFilter
- 
getTopicPartitioner
- 
getTranslator
- 
getFirstPollOffsetStrategy
- 
getPollTimeoutMspublic long getPollTimeoutMs()
- 
getPartitionRefreshPeriodMspublic long getPartitionRefreshPeriodMs()
- 
getStartTimeStamppublic long getStartTimeStamp()
- 
toString
 
-