Versions in this module Expand all Collapse all v1 v1.0.0 Mar 18, 2020 Changes in this version + func FromRecord(parent context.Context, record *data.Record) context.Context + func RecordFromContext(ctx context.Context, key []byte, val []byte) (*data.Record, error) + type Context struct + type RecordMeta struct + Headers []*sarama.RecordHeader + Offset int64 + Partition int32 + Timestamp time.Time + Topic string + func Meta(ctx context.Context) *RecordMeta
Go to main page