Hi, you can use "ProcessorContext" that is provided via init(). The context object is dynamically adjusted to the currently processed record
To get the offset, use "context.offset()". -Matthias On 05/22/2016 10:38 PM, Florian Hussonnois wrote: > Hi everyone, > > Is there any way to retrieve the offset attached to each message with the > APIs of kafka streams ? Currently the Processor interface exposes only the > method process(K key, V value); > > It would be usefull to get the offsets in order to implement DSL extensions > with some methods which need to identify each message. > > Thanks in advance >
signature.asc
Description: OpenPGP digital signature
