Estoy usando KaafkaJS para conectarme y consumir los mensajes de kafka. Estoy usando el siguiente código para consumir mensajes. Pero obtiene todos los mensajes, pero me gustaría almacenar el último mensaje en la variable messageValue . ¿Puede alguien ayudarme con eso, por favor?

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