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

Packages that use KafkaStreamSinkConfigurator

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

Uses of KafkaStreamSinkConfigurator in org.voltdb.stream.api

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

Modifier and Type	Method	Description
<P> KafkaStreamSinkConfigurator<P>	KafkaSinks.accepting(Class<P> vc)

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

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

Modifier and Type	Method	Description
static <P> KafkaStreamSinkConfigurator<P>	KafkaStreamSinkConfigurator.accepting(Class<P> vc)
KafkaStreamSinkConfigurator<T>	KafkaStreamSinkConfigurator.configure(String path)	configures the configurator using custom config path.
KafkaStreamSinkConfigurator<T>	KafkaStreamSinkConfigurator.withBootstrapServers(String bootstrapServers)
<K> KafkaStreamSinkConfigurator<T>	KafkaStreamSinkConfigurator.withHeaders(Function<T,Iterable<org.apache.kafka.common.header.Header>> extractorFunction)
KafkaStreamSinkConfigurator<T>	KafkaStreamSinkConfigurator.withKeyExtractor(Function<T,Long> extractorFunction)
<K> KafkaStreamSinkConfigurator<T>	KafkaStreamSinkConfigurator.withKeyExtractor(Function<T,K> extractorFunction, Class<? extends org.apache.kafka.common.serialization.Serializer<K>> serializerClass)
KafkaStreamSinkConfigurator<T>	KafkaStreamSinkConfigurator.withProperty(String key, boolean value)
KafkaStreamSinkConfigurator<T>	KafkaStreamSinkConfigurator.withProperty(String key, int value)
KafkaStreamSinkConfigurator<T>	KafkaStreamSinkConfigurator.withProperty(String key, long value)
KafkaStreamSinkConfigurator<T>	KafkaStreamSinkConfigurator.withProperty(String key, String value)
KafkaStreamSinkConfigurator<T>	KafkaStreamSinkConfigurator.withSchemaRegistry(String schemaRegistryUrl)
KafkaStreamSinkConfigurator<T>	KafkaStreamSinkConfigurator.withSSL(KafkaStreamSslConfiguration sslConfigurator)
KafkaStreamSinkConfigurator<T>	KafkaStreamSinkConfigurator.withTopicName(String topicName)
<K> KafkaStreamSinkConfigurator<T>	KafkaStreamSinkConfigurator.withValueExtractor(Function<T,K> extractorFunction, Class<? extends org.apache.kafka.common.serialization.Serializer<?>> serializerClass)
KafkaStreamSinkConfigurator<T>	KafkaStreamSinkConfigurator.withValueSerializer(Class<? extends org.apache.kafka.common.serialization.Serializer<?>> serializerClass)
KafkaStreamSinkConfigurator<T>	KafkaStreamSinkConfigurator.withValueSerializer(String serializerClass)