## 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 and Description
    --- | ---
    `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.
    `static KafkaSpoutConfig.Builder<String,String>` | KafkaSpoutConfig.`builder(String bootstrapServers, 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.`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
    Constructor and Description
    `KafkaSpoutConfig(KafkaSpoutConfig.Builder<K,V> builder)` Creates a new KafkaSpoutConfig using a Builder.

Copyright © 2021 The Apache Software Foundation. All rights reserved.