Consumer verticle
Michel Werren edited this page Apr 15, 2020
·
3 revisions
The consumer verticle is where the Kinesis records get consumed and finally delivered to the implementation of the function ch.sourcemotion.vertx.kinesis.consumer.orchestra.consumer.AbstractKinesisConsumerVerticle#onRecords. Therefore, you have to provide your own implementation of ch.sourcemotion.vertx.kinesis.consumer.orchestra.consumer.AbstractKinesisConsumerVerticle by applying the full qualified class name to the VKCO options ch.sourcemotion.vertx.kinesis.consumer.orchestra.VertxKinesisOrchestraOptions#consumerVerticleClass.
If you use Kotlin and prefer a suspendable variant, then you can use ch.sourcemotion.vertx.kinesis.consumer.orchestra.consumer.AbstractKinesisConsumerCoroutineVerticle as base consumer verticle.