It's not required to specify Consumed:

- the specified Serdes from Produced are used for the consumer, too
- it would be invalid to specify a custom extractor (for correctness
reasons, we enforce the default timestamp extractor)

Note, that Streams API sets the metadata record timestamp on write, and
thus, using the default timestamp extractor ensures that this timestamp
is correctly reused when reading data back.


On 2/2/18 3:54 PM, Dmitry Minkovsky wrote:
> `KStream#through()` currently lets you specify a `Produced`. Shouldn't it
> also let you specify a `Consumed`. This would let you specify a time stamp
> extractor.

Attachment: signature.asc
Description: OpenPGP digital signature

Reply via email to