Classes
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 |
Returns:
an instance of the KafkaConsumer
- Type
- KafkaConsumer