open static fun <K : Any, V : Any> create(vertx: Vertx, config: MutableMap<String, String>): KafkaConsumer<K, V>
Create a new KafkaConsumer instance
vertx - Vert.x instance to use
config - Kafka consumer configuration
Return
an instance of the KafkaConsumer
open static fun <K : Any, V : Any> create(vertx: Vertx, config: MutableMap<String, String>, keyType: Class<K>, valueType: Class<V>): KafkaConsumer<K, V>
Create a new KafkaConsumer 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 KafkaConsumer