Como posso obter o valor de deslocamento no KStream

Estou desenvolvendo um PoC com o Kafka Streams. Agora, preciso obter o valor de deslocamento no consumidor do fluxo e usá-lo para gerar uma chave exclusiva(topic-offset)->hash para cada mensagem. O motivo é: os produtores são syslog e apenas alguns deles têm IDs. Não consigo gerar um UUID no consumidor porque, em caso de reprocessamento, preciso gerar novamente a mesma chave.

Meu problema é: oorg.apache.kafka.streams.processor.ProcessorContext classe expor um.offset() método que retorna o valor, mas estou usando o KStream em vez do processador e não consegui encontrar um método que retorne a mesma coisa.

Alguém sabe como extrair o valor do consumidor para cada linha de um Kstream? desde já, obrigado