types

Documentation

Index

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

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 (*Message) ConsumerMessage

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