Poll one message/batch using kafkajs


This Content is from Stack Overflow. Question asked by caeus

Kafkajs creates a task that at a determined frequency polls messages from kafka, making it cumbersome to implement backpressure (not impossible).

I wonder if there’s an undocumented way of polling messages that allows me to implement something like this

async ()=>{
    const message = await consumer.poll()
    await handler(message)


This question is not yet answered, be the first one who answer using the comment. Later the confirmed answer will be published as the solution.

This Question and Answer are collected from stackoverflow and tested by JTuto community, is licensed under the terms of CC BY-SA 2.5. - CC BY-SA 3.0. - CC BY-SA 4.0.

people found this article helpful. What about you?