interface KafkaConsumer<K : Any, V : Any> : ReadStream<KafkaConsumerRecord<K, V>>
Vert.x Kafka consumer. You receive Kafka records by providing a The The |
|
interface KafkaConsumerRecords<K : Any, V : Any>
Vert.x Kafka consumer records |
|
interface KafkaReadStream<K : Any, V : Any> : ReadStream<ConsumerRecord<K, V>>
A ReadStream for consuming Kafka ConsumerRecord. The The |