kafka

Jul 31, 2018

Changes in this version

type Producer

+ Send func(ctx context.Context, msg *Message) error

Jul 8, 2018

Changes in this version

+ type AsyncProducer struct

+ func NewAsyncProducer(brokers []string) (*AsyncProducer, error)

+ func (ap *AsyncProducer) Close() error

+ func (ap *AsyncProducer) Error() <-chan error

+ func (ap *AsyncProducer) Send(ctx context.Context, msg *Message) error

+ type Message struct

+ func NewJSONMessage(t string, d interface{}) (*Message, error)

+ func NewMessage(t string, b []byte) *Message

+ type Producer interface

+ Close func() error

+ Error func() <-chan error

+ SendMessage func(ctx context.Context, msg *Message) error