Soy nuevo en Kafka y KafkaJS.
Estoy tratando de encontrar una manera de enviar los últimos n mensajes a un tema, en lugar de obtener todos los mensajes no consumidos de ese tema.
Por ejemplo, tengo un productor que produce 1 mensaje por segundo y lo dejo esperar 5 segundos.
Luego, cuando inicio el consumidor, el consumidor recibe los 5 mensajes. (Solo 1 consumidor en ejecución, 1 grupo, 1 partición, el mismo tema que el productor).
¿Existe una configuración en KafkaJS para obtener solo los últimos n mensajes producidos?
Puede sondear un solo registro o, de lo contrario, enumerar las compensaciones del tema de antemano.
Luego puede seek un consumidor en high_offset - N y comenzar a sondear desde allí