How do you consume the latest message from Kafka topic?

user_15330980 0
Viewed 109

I'm using KaafkaJS to connect and consume the kafka messsages. I'm using the following code to consume messages. But it fetches all the messages but I would like to store the last message in the variable messageValue. Can someone help me with it please.

await consumer.run({ 
            eachMessage: async (data) => {
                    messageValue = data.message.value.toString('utf8').trim()
            }
        })
console.log(messageValue)
kafkajs javascript
2 Answers
user_63861100

This below code worked for me. Reference

const consume = async () => {
    await consumer.connect()
    await consumer.subscribe({ topic, fromBeginning: true })
    await consumer.run({
        eachMessage: ({ message }) => { 
            console.log(`received message: ${message.value}`)
        },
    })
}
user_25737470
Related