Poll one message/batch using kafkajs

Viewed 29

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)
  }
}
0 Answers
Related