Uses of Class
com.hazelcast.jet.kafka.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(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'sProducerRecord
.