Class KafkaTridentSpoutConfig<K,V>
java.lang.Object
org.apache.storm.kafka.spout.internal.CommonKafkaSpoutConfig<K,V>
org.apache.storm.kafka.spout.trident.KafkaTridentSpoutConfig<K,V>
- All Implemented Interfaces:
Serializable
Defines the required Kafka-related configuration for the Trident spouts.
- See Also:
-
Nested Class Summary
-
Field Summary
Fields inherited from class org.apache.storm.kafka.spout.internal.CommonKafkaSpoutConfig
DEFAULT_FIRST_POLL_OFFSET_STRATEGY, DEFAULT_PARTITION_REFRESH_PERIOD_MS, DEFAULT_POLL_TIMEOUT_MS, DEFAULT_START_TS, LOG
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionFactory method that creates a Builder with String key/value deserializers.Factory method that creates a Builder with String key/value deserializers.Factory method that creates a Builder with String key/value deserializers.Methods inherited from class org.apache.storm.kafka.spout.internal.CommonKafkaSpoutConfig
getFirstPollOffsetStrategy, getKafkaProps, getPartitionRefreshPeriodMs, getPollTimeoutMs, getStartTimeStamp, getTopicFilter, getTopicPartitioner, getTranslator, toString
-
Constructor Details
-
KafkaTridentSpoutConfig
-
-
Method Details
-
builder
public static KafkaTridentSpoutConfig.Builder<String,String> builder(String bootstrapServers, String... topics) Factory method that creates a Builder with String key/value deserializers.- Parameters:
bootstrapServers
- The bootstrap servers for the consumertopics
- The topics to subscribe to- Returns:
- The new builder
-
builder
public static KafkaTridentSpoutConfig.Builder<String,String> builder(String bootstrapServers, Set<String> topics) Factory method that creates a Builder with String key/value deserializers.- Parameters:
bootstrapServers
- The bootstrap servers for the consumertopics
- The topics to subscribe to- Returns:
- The new builder
-
builder
public static KafkaTridentSpoutConfig.Builder<String,String> builder(String bootstrapServers, Pattern topics) Factory method that creates a Builder with String key/value deserializers.- Parameters:
bootstrapServers
- The bootstrap servers for the consumertopics
- The topic pattern to subscribe to- Returns:
- The new builder
-