Uses of Class
org.voltdb.stream.api.kafka.KafkaStreamSourceConfigurator

Packages that use KafkaStreamSourceConfigurator

Package	Description
org.voltdb.stream.api
org.voltdb.stream.api.kafka

Uses of KafkaStreamSourceConfigurator in org.voltdb.stream.api

Methods in org.voltdb.stream.api that return KafkaStreamSourceConfigurator

Modifier and Type	Method	Description
static KafkaStreamSourceConfigurator<ByteBuffer,ByteBuffer>	Sources.kafka()

Uses of KafkaStreamSourceConfigurator in org.voltdb.stream.api.kafka

Methods in org.voltdb.stream.api.kafka that return KafkaStreamSourceConfigurator

Modifier and Type	Method	Description
static KafkaStreamSourceConfigurator<ByteBuffer,ByteBuffer>	KafkaStreamSourceConfigurator.aConsumer()
KafkaStreamSourceConfigurator<K,V>	KafkaStreamSourceConfigurator.configure(String path)	configures the configurator using custom config path.
KafkaStreamSourceConfigurator<K,V>	KafkaStreamSourceConfigurator.withBootstrapServers(String bootstrapServers)
KafkaStreamSourceConfigurator<K,V>	KafkaStreamSourceConfigurator.withExceptionHandler(KafkaSourceExceptionHandler exceptionHandler)
KafkaStreamSourceConfigurator<K,V>	KafkaStreamSourceConfigurator.withGroupId(String groupId)
<KEY> KafkaStreamSourceConfigurator<KEY,V>	KafkaStreamSourceConfigurator.withKeyDeserializer(Class<? extends org.apache.kafka.common.serialization.Deserializer<KEY>> deserializerClass)
KafkaStreamSourceConfigurator<K,V>	KafkaStreamSourceConfigurator.withMaxCommitRetries(int retries)	KafkaSource will try to commit an offset and will retry this operation blocking its worker thread, but not more than this retry value.
KafkaStreamSourceConfigurator<K,V>	KafkaStreamSourceConfigurator.withMaxCommitTimeout(Duration timeout)	KafkaSource will try to commit an offset and will retry this operation blocking its worker thread, but not longer than this timeout value.
KafkaStreamSourceConfigurator<K,V>	KafkaStreamSourceConfigurator.withPollTimeout(Duration pollTimeout)	Defines timeout for consumer's poll call, default is 10 seconds.
KafkaStreamSourceConfigurator<K,V>	KafkaStreamSourceConfigurator.withProperty(String key, boolean value)
KafkaStreamSourceConfigurator<K,V>	KafkaStreamSourceConfigurator.withProperty(String key, int value)
KafkaStreamSourceConfigurator<K,V>	KafkaStreamSourceConfigurator.withProperty(String key, long value)
KafkaStreamSourceConfigurator<K,V>	KafkaStreamSourceConfigurator.withProperty(String key, String value)
KafkaStreamSourceConfigurator<K,V>	KafkaStreamSourceConfigurator.withSchemaRegistryUrl(String schemaUrl)
KafkaStreamSourceConfigurator<K,V>	KafkaStreamSourceConfigurator.withSSL(KafkaStreamSslConfiguration sslConfigurator)
KafkaStreamSourceConfigurator<K,V>	KafkaStreamSourceConfigurator.withStartingOffset(KafkaStartingOffset startingOffsets)
KafkaStreamSourceConfigurator<K,V>	KafkaStreamSourceConfigurator.withTopicNames(String topicNames)	Define topics names used by this kafka source
<VALUE> KafkaStreamSourceConfigurator<K,VALUE>	KafkaStreamSourceConfigurator.withValueDeserializer(Class<? extends org.apache.kafka.common.serialization.Deserializer<?>> deserializerClass, Class<VALUE> deserializedType)
<VALUE> KafkaStreamSourceConfigurator<K,VALUE>	KafkaStreamSourceConfigurator.withValueDeserializer(Class<? extends org.apache.kafka.common.serialization.Deserializer<VALUE>> deserializerClass)