Uses of Class
com.github.hekonsek.rxjava.connector.kafka.KafkaEventAdapter

Uses of KafkaEventAdapter in com.github.hekonsek.rxjava.connector.kafka

Methods in com.github.hekonsek.rxjava.connector.kafka that return KafkaEventAdapter

Modifier and Type	Method and Description
static <X,Y> KafkaEventAdapter<X,Y>	KafkaEventAdapter.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>>	KafkaEventAdapter.stringAndBytesToMap()

Methods in com.github.hekonsek.rxjava.connector.kafka with parameters of type KafkaEventAdapter

Modifier and Type	Method and Description
KafkaSource<K,V>	KafkaSource.eventAdapter(KafkaEventAdapter<K,V> eventAdapter)