Uses of Class
com.hazelcast.jet.kafka.KafkaSinks.Builder

Packages that use KafkaSinks.Builder

Package	Description
com.hazelcast.jet.kafka	Apache Kafka reader/writer support for Hazelcast Jet.

Uses of KafkaSinks.Builder in com.hazelcast.jet.kafka

Methods in com.hazelcast.jet.kafka that return KafkaSinks.Builder

Modifier and Type	Method	Description
KafkaSinks.Builder<E>	KafkaSinks.Builder.exactlyOnce(boolean enable)	Enables or disables the exactly-once behavior of the sink using two-phase commit of state snapshots.
KafkaSinks.Builder<E>	KafkaSinks.Builder.extractKeyFn(FunctionEx<? super E,?> extractKeyFn)	Sets the function to extract the key from the stream items.
KafkaSinks.Builder<E>	KafkaSinks.Builder.extractValueFn(FunctionEx<? super E,?> extractValueFn)	Sets the function to extract the value from the stream items.
static <E> KafkaSinks.Builder<E>	KafkaSinks.kafka(DataConnectionRef dataConnectionRef)	Returns a builder object that you can use to create an Apache Kafka pipeline sink.
static <E> KafkaSinks.Builder<E>	KafkaSinks.kafka(Properties properties)	Returns a builder object that you can use to create an Apache Kafka pipeline sink.
KafkaSinks.Builder<E>	KafkaSinks.Builder.topic(String topic)	Sets the topic to write the messages to, if you write all messages to a single topic.
KafkaSinks.Builder<E>	KafkaSinks.Builder.toRecordFn(FunctionEx<? super E,? extends org.apache.kafka.clients.producer.ProducerRecord<?,?>> toRecordFn)	Sets the function to convert stream items into Kafka's ProducerRecord.