Class KafkaTridentSpoutConfig.Builder<K,V>
java.lang.Object
org.apache.storm.kafka.spout.internal.CommonKafkaSpoutConfig.Builder<K,V,KafkaTridentSpoutConfig.Builder<K,V>>
org.apache.storm.kafka.spout.trident.KafkaTridentSpoutConfig.Builder<K,V>
- Enclosing class:
- KafkaTridentSpoutConfig<K,
V>
public static class KafkaTridentSpoutConfig.Builder<K,V>
extends CommonKafkaSpoutConfig.Builder<K,V,KafkaTridentSpoutConfig.Builder<K,V>>
-
Constructor Summary
-
Method Summary
Methods inherited from class org.apache.storm.kafka.spout.internal.CommonKafkaSpoutConfig.Builder
getKafkaProps, setFirstPollOffsetStrategy, setPartitionRefreshPeriodMs, setPollTimeoutMs, setProp, setProp, setProp, setRecordTranslator, setRecordTranslator, setRecordTranslator, setStartTimeStamp
-
Constructor Details
-
Builder
-
Builder
-
Builder
-
Builder
public Builder(String bootstrapServers, TopicFilter topicFilter, ManualPartitioner topicPartitioner)
-
-
Method Details
-
build
- Specified by:
build
in classCommonKafkaSpoutConfig.Builder<K,
V, KafkaTridentSpoutConfig.Builder<K, V>>
-