com.hazelcast.jet.core.processor

Class KafkaProcessors

java.lang.Object

com.hazelcast.jet.core.processor.KafkaProcessors

public final class KafkaProcessors
extends Object

Static utility class with factories of Apache Kafka source and sink processors.

Method Summary

Modifier and Type	Method and Description
static <K,V,T> ProcessorMetaSupplier	streamKafkaP(Properties properties, DistributedBiFunction<K,V,T> projectionFn, String... topics) Returns a supplier of processors for KafkaSources.kafka(Properties, DistributedBiFunction, String...).
static ProcessorMetaSupplier	streamKafkaP(Properties properties, String... topics) Returns a supplier of processors for KafkaSources.kafka(Properties, String...).
static <T,K,V> ProcessorMetaSupplier	writeKafkaP(Properties properties, DistributedFunction<? super T,org.apache.kafka.clients.producer.ProducerRecord<K,V>> toRecordFn) Returns a supplier of processors for KafkaSinks.kafka(Properties, DistributedFunction).
static <T,K,V> ProcessorMetaSupplier	writeKafkaP(Properties properties, String topic, DistributedFunction<? super T,K> extractKeyFn, DistributedFunction<? super T,V> extractValueFn) Returns a supplier of processors for KafkaSinks.kafka(Properties, String, DistributedFunction, DistributedFunction).

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

streamKafkaP

public static <K,V,T> ProcessorMetaSupplier streamKafkaP(@Nonnull
                                                         Properties properties,
                                                         @Nonnull
                                                         DistributedBiFunction<K,V,T> projectionFn,
                                                         @Nonnull
                                                         String... topics)

Returns a supplier of processors for KafkaSources.kafka(Properties, DistributedBiFunction, String...).

streamKafkaP

public static ProcessorMetaSupplier streamKafkaP(@Nonnull
                                                 Properties properties,
                                                 @Nonnull
                                                 String... topics)

Returns a supplier of processors for KafkaSources.kafka(Properties, String...).

writeKafkaP

public static <T,K,V> ProcessorMetaSupplier writeKafkaP(@Nonnull
                                                        Properties properties,
                                                        @Nonnull
                                                        String topic,
                                                        @Nonnull
                                                        DistributedFunction<? super T,K> extractKeyFn,
                                                        @Nonnull
                                                        DistributedFunction<? super T,V> extractValueFn)

Returns a supplier of processors for KafkaSinks.kafka(Properties, String, DistributedFunction, DistributedFunction).

writeKafkaP

public static <T,K,V> ProcessorMetaSupplier writeKafkaP(@Nonnull
                                                        Properties properties,
                                                        @Nonnull
                                                        DistributedFunction<? super T,org.apache.kafka.clients.producer.ProducerRecord<K,V>> toRecordFn)

Returns a supplier of processors for KafkaSinks.kafka(Properties, DistributedFunction).