Package com.hazelcast.jet.kafka
Class KafkaProcessors
java.lang.Object
com.hazelcast.jet.kafka.KafkaProcessors
public final class KafkaProcessors extends Object
Static utility class with factories of Apache Kafka source and sink
processors.
- Since:
- 3.0
-
Method Summary
Modifier and Type Method Description static <K, V, T> ProcessorMetaSupplier
streamKafkaP(Properties properties, FunctionEx<? super org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,? extends T> projectionFn, EventTimePolicy<? super T> eventTimePolicy, String... topics)
Returns a supplier of processors forKafkaSources.kafka(Properties, FunctionEx, String...)
.static <T, K, V> ProcessorMetaSupplier
writeKafkaP(Properties properties, FunctionEx<? super T,? extends org.apache.kafka.clients.producer.ProducerRecord<K,V>> toRecordFn, boolean exactlyOnce)
Returns a supplier of processors forKafkaSinks.kafka(Properties, FunctionEx)
.static <T, K, V> ProcessorMetaSupplier
writeKafkaP(Properties properties, String topic, FunctionEx<? super T,? extends K> extractKeyFn, FunctionEx<? super T,? extends V> extractValueFn, boolean exactlyOnce)
Returns a supplier of processors forKafkaSinks.kafka(Properties, String, FunctionEx, FunctionEx)
.
-
Method Details
-
streamKafkaP
public static <K, V, T> ProcessorMetaSupplier streamKafkaP(@Nonnull Properties properties, @Nonnull FunctionEx<? super org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,? extends T> projectionFn, @Nonnull EventTimePolicy<? super T> eventTimePolicy, @Nonnull String... topics)Returns a supplier of processors forKafkaSources.kafka(Properties, FunctionEx, String...)
. -
writeKafkaP
public static <T, K, V> ProcessorMetaSupplier writeKafkaP(@Nonnull Properties properties, @Nonnull String topic, @Nonnull FunctionEx<? super T,? extends K> extractKeyFn, @Nonnull FunctionEx<? super T,? extends V> extractValueFn, boolean exactlyOnce)Returns a supplier of processors forKafkaSinks.kafka(Properties, String, FunctionEx, FunctionEx)
. -
writeKafkaP
public static <T, K, V> ProcessorMetaSupplier writeKafkaP(@Nonnull Properties properties, @Nonnull FunctionEx<? super T,? extends org.apache.kafka.clients.producer.ProducerRecord<K,V>> toRecordFn, boolean exactlyOnce)Returns a supplier of processors forKafkaSinks.kafka(Properties, FunctionEx)
.
-