Package | Description |
---|---|
org.apache.storm.kafka.spout |
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 . |
Constructor and Description |
---|
KafkaSpoutConfig(KafkaSpoutConfig.Builder<K,V> builder)
Creates a new KafkaSpoutConfig using a Builder.
|
Copyright © 2023 The Apache Software Foundation. All rights reserved.