public final class KafkaProcessors extends Object
Modifier and Type | Method and 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 for
KafkaSources.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 for
KafkaSinks.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 for
KafkaSinks.kafka(Properties, String, FunctionEx, FunctionEx) . |
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)
KafkaSources.kafka(Properties, FunctionEx, String...)
.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)
KafkaSinks.kafka(Properties, String, FunctionEx, FunctionEx)
.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)
KafkaSinks.kafka(Properties, FunctionEx)
.Copyright © 2022 Hazelcast, Inc.. All rights reserved.