kafka

Documentation

Index

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

Functions

func NewKafkaReceiver

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

func NewKafkaSender

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

func NewMessage

func NewMessage(topic string, key string, value []byte) event.Event

Types

type Message

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

func (*Message) Key

func (m *Message) Key() string

func (*Message) Topic

func (m *Message) Topic() string

func (*Message) Value

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