Uses of Class
org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder

Packages that use KafkaSpoutConfig.Builder

Package	Description
org.apache.storm.kafka.spout

Uses of KafkaSpoutConfig.Builder in org.apache.storm.kafka.spout

Methods in org.apache.storm.kafka.spout that return KafkaSpoutConfig.Builder

Modifier and Type	Method	Description
static KafkaSpoutConfig.Builder<String,String>	KafkaSpoutConfig.builder(String bootstrapServers, String... topics)	Factory method that creates a Builder with String key/value deserializers.
static KafkaSpoutConfig.Builder<String,String>	KafkaSpoutConfig.builder(String bootstrapServers, Pattern topics)	Factory method that creates a Builder with String key/value deserializers.
static KafkaSpoutConfig.Builder<String,String>	KafkaSpoutConfig.builder(String bootstrapServers, Set<String> topics)	Factory method that creates a Builder with String key/value deserializers.
KafkaSpoutConfig.Builder<K,V>	KafkaSpoutConfig.Builder.setEmitNullTuples(boolean emitNullTuples)	Specifies if the spout should emit null tuples to the component downstream, or rather not emit and directly ack them.
KafkaSpoutConfig.Builder<K,V>	KafkaSpoutConfig.Builder.setGroupId(String groupId)	Specifies the group id.
KafkaSpoutConfig.Builder<K,V>	KafkaSpoutConfig.Builder.setMaxUncommittedOffsets(int maxUncommittedOffsets)	Defines the max number of polled offsets (records) that can be pending commit, before another poll can take place.
KafkaSpoutConfig.Builder<K,V>	KafkaSpoutConfig.Builder.setMetricsTimeBucketSizeInSecs(int metricsTimeBucketSizeInSecs)	The time period that metrics data in bucketed into.
KafkaSpoutConfig.Builder<K,V>	KafkaSpoutConfig.Builder.setOffsetCommitPeriodMs(long offsetCommitPeriodMs)	Specifies the period, in milliseconds, the offset commit task is periodically called.
KafkaSpoutConfig.Builder<K,V>	KafkaSpoutConfig.Builder.setProcessingGuarantee(KafkaSpoutConfig.ProcessingGuarantee processingGuarantee)	Specifies which processing guarantee the spout should offer.
KafkaSpoutConfig.Builder<K,V>	KafkaSpoutConfig.Builder.setRetry(KafkaSpoutRetryService retryService)	Sets the retry service for the spout to use.
KafkaSpoutConfig.Builder<K,V>	KafkaSpoutConfig.Builder.setTupleListener(KafkaTupleListener tupleListener)	Sets the tuple listener for the spout to use.
KafkaSpoutConfig.Builder<K,V>	KafkaSpoutConfig.Builder.setTupleTrackingEnforced(boolean tupleTrackingEnforced)	Specifies whether the spout should require Storm to track emitted tuples when using a KafkaSpoutConfig.ProcessingGuarantee other than KafkaSpoutConfig.ProcessingGuarantee.AT_LEAST_ONCE.

Constructors in org.apache.storm.kafka.spout with parameters of type KafkaSpoutConfig.Builder

Modifier	Constructor	Description
	KafkaSpoutConfig(KafkaSpoutConfig.Builder<K,V> builder)	Creates a new KafkaSpoutConfig using a Builder.