open static fun <K : Any, V : Any> create(vertx: Vertx, config: Properties): KafkaReadStream<K, V>open static fun <K : Any, V : Any> create(vertx: Vertx, config: MutableMap<String, Any>): KafkaReadStream<K, V>
Create a new KafkaReadStream instance
vertx - Vert.x instance to use
config - Kafka consumer configuration
Return
an instance of the KafkaReadStream
open static fun <K : Any, V : Any> create(vertx: Vertx, config: Properties, keyType: Class<K>, valueType: Class<V>): KafkaReadStream<K, V>open static fun <K : Any, V : Any> create(vertx: Vertx, config: MutableMap<String, Any>, keyType: Class<K>, valueType: Class<V>): KafkaReadStream<K, V>
Create a new KafkaReadStream instance
vertx - Vert.x instance to use
config - Kafka consumer configuration
keyType - class type for the key deserialization
valueType - class type for the value deserialization
Return
an instance of the KafkaReadStream
open static fun <K : Any, V : Any> create(vertx: Vertx, consumer: Consumer<K, V>): KafkaReadStream<K, V>
Create a new KafkaReadStream instance
vertx - Vert.x instance to use
consumer - native Kafka consumer instance
Return
an instance of the KafkaReadStream