com.github.hekonsek.rxjava.connector.kafka

Class KafkaSource<K,V>

java.lang.Object

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

public class KafkaSource<K,V>
extends Object

Constructor Summary

Constructors

Constructor and Description
KafkaSource(io.vertx.reactivex.core.Vertx vertx, String topic)

Method Summary

Modifier and Type	Method and Description
KafkaSource<K,V>	bootstrapServers(String bootstrapServers)
io.reactivex.Observable<com.github.hekonsek.rxjava.event.Event<V>>	build()
KafkaSource<K,V>	eventAdapter(KafkaEventAdapter<K,V> eventAdapter)
KafkaSource<K,V>	groupId(String groupId)

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaSource

public KafkaSource(io.vertx.reactivex.core.Vertx vertx,
                   String topic)

Method Detail

build

public io.reactivex.Observable<com.github.hekonsek.rxjava.event.Event<V>> build()

bootstrapServers

public KafkaSource<K,V> bootstrapServers(String bootstrapServers)

groupId

public KafkaSource<K,V> groupId(String groupId)

eventAdapter

public KafkaSource<K,V> eventAdapter(KafkaEventAdapter<K,V> eventAdapter)