Expose timestamp on messages
@@ -118,8 +118,9 @@ func (a *apiServer) consumeStream(ctx context.Context, stream *stream, req *clie
msg = &client.Message{
Offset: offset,
Key: m.Key,
- Reply: reply,
Value: m.Value[4+replySize:],
+ Reply: reply,
+ Timestamp: m.Timestamp.UnixNano(),
}
)
ch <- msg
