message

Documentation

Index

• type Header
  • func NewHeader(header kafka.Header) *Header
  • func NewHeaderFromKV(key string, value string) *Header
  • func (h *Header) Key() string
  • func (h *Header) Value() string
• type Message
  • func NewMessage(msg *kafka.Message) *Message
  • func (m *Message) Headers() []types.Header
  • func (m *Message) Key() []byte
  • func (m *Message) Offset() int64
  • func (m *Message) Partition() int
  • func (m *Message) Topic() string
  • func (m *Message) Value() []byte

Types

type Header

type Header struct {
	// contains filtered or unexported fields
}

KafkaHeader es un adaptador para kafka.Header que implementa types.Header

func NewHeader

func NewHeader(header kafka.Header) *Header

func NewHeaderFromKV

func NewHeaderFromKV(key string, value string) *Header

func (*Header) Key

func (h *Header) Key() string

func (*Header) Value

func (h *Header) Value() string

type Message

type Message struct {
	// contains filtered or unexported fields
}

func NewMessage

func NewMessage(msg *kafka.Message) *Message

func (*Message) Headers

func (m *Message) Headers() []types.Header

func (*Message) Key

func (m *Message) Key() []byte

func (*Message) Offset

func (m *Message) Offset() int64

func (*Message) Partition

func (m *Message) Partition() int

func (*Message) Topic

func (m *Message) Topic() string

func (*Message) Value

func (m *Message) Value() []byte