types

type Message ¶

type Message struct {
	Offset    int64
	Key       []byte
	Value     []byte
	Timestamp time.Time
	Headers   []sarama.RecordHeader
}

A Message is used internally within naffka to store messages. It is converted to a sarama.ConsumerMessage when exposed to the public APIs to maintain API compatibility with sarama.

func (m *Message) ConsumerMessage(topic string) *sarama.ConsumerMessage