Questions tagged [vertx-kafka-client]

I have a Java application that uses the Vertx framework and Kafka. There is a Kafka consumer with a handler containing my custom code and a Vertx router that simply returns an "OK" to the requests. While consuming messages from the topic, it happens…

Setup: 1 Topic (test-topic) with 4 partitions Vert.x: 4.0.3 RxJava2 : 2.2.12 Vert.x internally uses kafka-client: 2.6.0 Kafka broker: 2.8.1 Scenario 1: When 1 consumer group with 1 consumer is used, the system takes 60 seconds to complete…

protected void consume(KafkaReadStream consumer) { consumer.handler(record -> { // call a REST API to write a value to DB doRestApi(record); // such as client.postAbs(...).send(...) }); …