com.github.hekonsek.rxjava.connector.kafka

Class KafkaEventAdapter<K,V>

java.lang.Object

com.github.hekonsek.rxjava.connector.kafka.KafkaEventAdapter<K,V>

public class KafkaEventAdapter<K,V>
extends Object

Constructor Summary

Constructors

Constructor and Description
KafkaEventAdapter(Class<? extends org.apache.kafka.common.serialization.Deserializer> keyDeserializer, Class<? extends org.apache.kafka.common.serialization.Deserializer> valueDeserializer, io.reactivex.functions.Function<io.vertx.reactivex.kafka.client.consumer.KafkaConsumerRecord<K,V>,com.github.hekonsek.rxjava.event.Event<V>> mapping)

Method Summary

Modifier and Type	Method and Description
Class<? extends org.apache.kafka.common.serialization.Deserializer>	keyDeserializer()
io.reactivex.functions.Function<io.vertx.reactivex.kafka.client.consumer.KafkaConsumerRecord<K,V>,com.github.hekonsek.rxjava.event.Event<V>>	mapping()
static <X,Y> KafkaEventAdapter<X,Y>	simpleMapping(Class<? extends org.apache.kafka.common.serialization.Deserializer<X>> keyDeserializer, Class<? extends org.apache.kafka.common.serialization.Deserializer<Y>> valueDeserializer)
static KafkaEventAdapter<String,Map<String,Object>>	stringAndJsonBytesToMap()
Class<? extends org.apache.kafka.common.serialization.Deserializer>	valueDeserializer()

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaEventAdapter

public KafkaEventAdapter(Class<? extends org.apache.kafka.common.serialization.Deserializer> keyDeserializer,
                         Class<? extends org.apache.kafka.common.serialization.Deserializer> valueDeserializer,
                         io.reactivex.functions.Function<io.vertx.reactivex.kafka.client.consumer.KafkaConsumerRecord<K,V>,com.github.hekonsek.rxjava.event.Event<V>> mapping)

Method Detail

stringAndJsonBytesToMap

public static KafkaEventAdapter<String,Map<String,Object>> stringAndJsonBytesToMap()

simpleMapping

public static <X,Y> KafkaEventAdapter<X,Y> simpleMapping(Class<? extends org.apache.kafka.common.serialization.Deserializer<X>> keyDeserializer,
                                                         Class<? extends org.apache.kafka.common.serialization.Deserializer<Y>> valueDeserializer)

keyDeserializer

public Class<? extends org.apache.kafka.common.serialization.Deserializer> keyDeserializer()

valueDeserializer

public Class<? extends org.apache.kafka.common.serialization.Deserializer> valueDeserializer()

mapping

public io.reactivex.functions.Function<io.vertx.reactivex.kafka.client.consumer.KafkaConsumerRecord<K,V>,com.github.hekonsek.rxjava.event.Event<V>> mapping()