kafka

Documentation

Index

• func NewKafkaReceiver(address []string, topic string) (event.Receiver, error)
• func NewKafkaSender(address []string, topic string) (event.Sender, error)
• func NewMessage(key string, value []byte, header map[string]string) event.Message
• type Message
  • func (m *Message) Header() map[string]string
  • func (m *Message) Key() string
  • func (m *Message) Value() []byte

Functions

func NewKafkaReceiver

func NewKafkaReceiver(address []string, topic string) (event.Receiver, error)

func NewKafkaSender

func NewKafkaSender(address []string, topic string) (event.Sender, error)

func NewMessage

func NewMessage(key string, value []byte, header map[string]string) event.Message

Types

type Message

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

func (*Message) Header

func (m *Message) Header() map[string]string

func (*Message) Key

func (m *Message) Key() string

func (*Message) Value

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