Я разрабатываю PoC с Kafka Streams. Теперь мне нужно получить значение смещения в потоке потребителя и использовать его для генерации уникального ключа.(topic-offset)->hash за каждое сообщение. Причина в том, что производители являются системными журналами, и только немногие из них имеют идентификаторы. Я не могу сгенерировать UUID у потребителя, потому что в случае повторной обработки мне нужно восстановить тот же ключ.

Моя проблема:org.apache.kafka.streams.processor.ProcessorContext класс разоблачить.offset() метод, который возвращает значение, но я использую KStream вместо Processor, и я не смог найти метод, который возвращает ту же самую вещь.

Кто-нибудь знает, как извлечь потребительское значение для каждой строки из Kstream? заранее спасибо