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 th
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 nee
