public final class KafkaProcessors extends Object
public static <K,V,T> ProcessorMetaSupplier streamKafkaP(@Nonnull Properties properties, @Nonnull DistributedBiFunction<K,V,T> projectionFn, @Nonnull String... topics)
KafkaSources.kafka(Properties, DistributedBiFunction, String...)
.public static ProcessorMetaSupplier streamKafkaP(@Nonnull Properties properties, @Nonnull String... topics)
KafkaSources.kafka(Properties, String...)
.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)
KafkaSinks.kafka(Properties, String, DistributedFunction, DistributedFunction)
.public static <T,K,V> ProcessorMetaSupplier writeKafkaP(@Nonnull Properties properties, @Nonnull DistributedFunction<? super T,org.apache.kafka.clients.producer.ProducerRecord<K,V>> toRecordFn)
KafkaSinks.kafka(Properties, DistributedFunction)
.Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.