Package | Description |
---|---|
org.apache.storm.kafka.spout |
Modifier and Type | Method and Description |
---|---|
static KafkaSpoutConfig.Builder<String,String> |
KafkaSpoutConfig.builder(String bootstrapServers,
Collection<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,
String... topics)
Factory method that creates a Builder with String key/value deserializers.
|
KafkaSpoutConfig.Builder<K,V> |
KafkaSpoutConfig.Builder.setBootstrapServers(String servers)
Deprecated.
Please use
setProp(java.lang.String, java.lang.Object) with ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG instead |
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.setFetchMinBytes(int bytes)
Deprecated.
Please use
setProp(java.lang.String, java.lang.Object) with ConsumerConfig.FETCH_MIN_BYTES_CONFIG instead |
KafkaSpoutConfig.Builder<K,V> |
KafkaSpoutConfig.Builder.setFirstPollOffsetStrategy(KafkaSpoutConfig.FirstPollOffsetStrategy firstPollOffsetStrategy)
Sets the offset used by the Kafka spout in the first poll to Kafka broker upon process start.
|
KafkaSpoutConfig.Builder<K,V> |
KafkaSpoutConfig.Builder.setGroupId(String id)
Deprecated.
Please use
setProp(java.lang.String, java.lang.Object) with ConsumerConfig.GROUP_ID_CONFIG instead |
<NK> KafkaSpoutConfig.Builder<NK,V> |
KafkaSpoutConfig.Builder.setKey(Class<? extends org.apache.kafka.common.serialization.Deserializer<NK>> clazz)
Deprecated.
Please use
setProp(java.lang.String, java.lang.Object) with ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG instead |
<NK> KafkaSpoutConfig.Builder<NK,V> |
KafkaSpoutConfig.Builder.setKey(SerializableDeserializer<NK> keyDeserializer)
Deprecated.
Please use
setProp(java.lang.String, java.lang.Object) with ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG instead |
KafkaSpoutConfig.Builder<K,V> |
KafkaSpoutConfig.Builder.setMaxPartitionFectchBytes(int bytes)
Deprecated.
Please use
setProp(java.lang.String, java.lang.Object) with ConsumerConfig.MAX_PARTITION_FETCH_BYTES_CONFIG instead |
KafkaSpoutConfig.Builder<K,V> |
KafkaSpoutConfig.Builder.setMaxPollRecords(int records)
Deprecated.
Please use
setProp(java.lang.String, java.lang.Object) with ConsumerConfig.MAX_POLL_RECORDS_CONFIG instead |
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.setPartitionRefreshPeriodMs(long partitionRefreshPeriodMs)
Sets partition refresh period in milliseconds.
|
KafkaSpoutConfig.Builder<K,V> |
KafkaSpoutConfig.Builder.setPollTimeoutMs(long pollTimeoutMs)
Specifies the time, in milliseconds, spent waiting in poll if data is not available.
|
KafkaSpoutConfig.Builder<K,V> |
KafkaSpoutConfig.Builder.setProcessingGuarantee(KafkaSpoutConfig.ProcessingGuarantee processingGuarantee)
Specifies which processing guarantee the spout should offer.
|
KafkaSpoutConfig.Builder<K,V> |
KafkaSpoutConfig.Builder.setProp(Map<String,Object> props)
Set multiple
KafkaConsumer properties. |
KafkaSpoutConfig.Builder<K,V> |
KafkaSpoutConfig.Builder.setProp(Properties props)
Set multiple
KafkaConsumer properties. |
KafkaSpoutConfig.Builder<K,V> |
KafkaSpoutConfig.Builder.setProp(String key,
Object value)
Set a
KafkaConsumer property. |
KafkaSpoutConfig.Builder<K,V> |
KafkaSpoutConfig.Builder.setRecordTranslator(Func<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,List<Object>> func,
Fields fields)
Configure a translator with tuples to be emitted on the default stream.
|
KafkaSpoutConfig.Builder<K,V> |
KafkaSpoutConfig.Builder.setRecordTranslator(Func<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,List<Object>> func,
Fields fields,
String stream)
Configure a translator with tuples to be emitted to a given stream.
|
KafkaSpoutConfig.Builder<K,V> |
KafkaSpoutConfig.Builder.setRecordTranslator(RecordTranslator<K,V> translator) |
KafkaSpoutConfig.Builder<K,V> |
KafkaSpoutConfig.Builder.setRetry(KafkaSpoutRetryService retryService)
Sets the retry service for the spout to use.
|
KafkaSpoutConfig.Builder<K,V> |
KafkaSpoutConfig.Builder.setSecurityProtocol(String protocol)
Deprecated.
Please use
setProp(java.lang.String, java.lang.Object) with “security.protocol” instead |
KafkaSpoutConfig.Builder<K,V> |
KafkaSpoutConfig.Builder.setSSLKeystore(String location,
String password)
Deprecated.
Please use
setProp(java.lang.String, java.lang.Object) with “ssl.keystore.location” and “ssl.keystore.password” instead |
KafkaSpoutConfig.Builder<K,V> |
KafkaSpoutConfig.Builder.setSSLKeystore(String location,
String password,
String keyPassword)
Deprecated.
Please use
setProp(java.lang.String, java.lang.Object) with “ssl.keystore.location”, “ssl.keystore.password” and “ssl.key.password” instead |
KafkaSpoutConfig.Builder<K,V> |
KafkaSpoutConfig.Builder.setSSLTruststore(String location,
String password)
Deprecated.
Please use
setProp(java.lang.String, java.lang.Object) with “security.protocol”, “ssl.truststore.location” and “ssl.truststore.password” instead |
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 . |
<NV> KafkaSpoutConfig.Builder<K,NV> |
KafkaSpoutConfig.Builder.setValue(Class<? extends org.apache.kafka.common.serialization.Deserializer<NV>> clazz)
Deprecated.
Please use
setProp(java.lang.String, java.lang.Object) with ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG instead |
<NV> KafkaSpoutConfig.Builder<K,NV> |
KafkaSpoutConfig.Builder.setValue(SerializableDeserializer<NV> valueDeserializer)
Deprecated.
Please use
setProp(java.lang.String, java.lang.Object) with ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG instead |
Constructor and Description |
---|
KafkaSpoutConfig(KafkaSpoutConfig.Builder<K,V> builder)
Creates a new KafkaSpoutConfig using a Builder.
|
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.