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()

Method Summary

Modifier and Type	Method and Description
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>>	stringAndBytesToMap()

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaEventAdapter

public KafkaEventAdapter()

Method Detail

stringAndBytesToMap

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

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)