Estoy desarrollando un PoC con Kafka Streams. Ahora necesito obtener el valor de compensación en el consumidor continuo y usarlo para generar una clave única(topic-offset)->hash para cada mensaje La razón es que los productores son syslog y solo unos pocos tienen identificaciones. No puedo generar un UUID en el consumidor porque en caso de reprocesamiento necesito regenerar la misma clave.

Mi problema es: elorg.apache.kafka.streams.processor.ProcessorContext clase exponer un.offset() método que devuelve el valor, pero estoy usando KStream en lugar del procesador, y no pude encontrar un método que devuelva lo mismo.

¿Alguien sabe cómo extraer el valor del consumidor para cada fila de un Kstream? gracias por adelantado