Uses of Class
org.apache.storm.kafka.spout.KafkaSpoutConfig.Builder
Packages that use KafkaSpoutConfig.Builder
-
Uses of KafkaSpoutConfig.Builder in org.apache.storm.kafka.spout
Methods in org.apache.storm.kafka.spout that return KafkaSpoutConfig.BuilderModifier and TypeMethodDescriptionstatic KafkaSpoutConfig.Builder<String,String> Factory method that creates a Builder with String key/value deserializers.static KafkaSpoutConfig.Builder<String,String> Factory method that creates a Builder with String key/value deserializers.static KafkaSpoutConfig.Builder<String,String> Factory method that creates a Builder with String key/value deserializers.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.setGroupId(String groupId) Specifies the group id.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.setMetricsTimeBucketSizeInSecs(int metricsTimeBucketSizeInSecs) The time period that metrics data in bucketed into.KafkaSpoutConfig.Builder.setOffsetCommitPeriodMs(long offsetCommitPeriodMs) Specifies the period, in milliseconds, the offset commit task is periodically called.KafkaSpoutConfig.Builder.setProcessingGuarantee(KafkaSpoutConfig.ProcessingGuarantee processingGuarantee) Specifies which processing guarantee the spout should offer.KafkaSpoutConfig.Builder.setRetry(KafkaSpoutRetryService retryService) Sets the retry service for the spout to use.KafkaSpoutConfig.Builder.setTupleListener(KafkaTupleListener tupleListener) Sets the tuple listener for the spout to use.KafkaSpoutConfig.Builder.setTupleTrackingEnforced(boolean tupleTrackingEnforced) Specifies whether the spout should require Storm to track emitted tuples when using aKafkaSpoutConfig.ProcessingGuaranteeother thanKafkaSpoutConfig.ProcessingGuarantee.AT_LEAST_ONCE.Constructors in org.apache.storm.kafka.spout with parameters of type KafkaSpoutConfig.BuilderModifierConstructorDescriptionKafkaSpoutConfig(KafkaSpoutConfig.Builder<K, V> builder) Creates a new KafkaSpoutConfig using a Builder.