kafka-streams-scala
kafka-streams-scala copied to clipboard
Timestamp extractor not supported
trafficstars
The Consumed class can be provided with TimstampExtractor.
I suggest add this to the wrapper API.
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.