Module: vertx-kafka-client-js/kafka_consumer

Classes

KafkaConsumer

Methods

(static) KafkaConsumer.create(vertx, config, keyType, valueType) → {KafkaConsumer}

Create a new KafkaConsumer instance
Parameters:
Name Type Description
vertx Vertx Vert.x instance to use
config Array.<string> Kafka consumer configuration
keyType todo class type for the key deserialization
valueType todo class type for the value deserialization
Source:
Returns:
an instance of the KafkaConsumer
Type
KafkaConsumer