Issue

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 ()=>{
  while(true){
    const message = await consumer.poll()
    await handler(message)
  }
}

Solution

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.