kafka-streams-scala icon indicating copy to clipboard operation
kafka-streams-scala copied to clipboard

Published 20 hours ago • verified publisher icon lightbend

Timestamp extractor not supported

Open pacman899 opened this issue 6 years ago • 1 comments

The Consumed class can be provided with TimstampExtractor.
I suggest add this to the wrapper API.

pacman899 avatar Mar 25 '18 14:03 pacman899

The APIs that take Consumed can always pass an instance of Consumed with TimestampExtractor. I am not sure I understand what the wrapper API needs to provide here.

debasishg avatar Apr 03 '18 05:04 debasishg