Versions in this module Expand all Collapse all v0 v0.0.1 Jan 25, 2022 Changes in this version + type ConsumerHandler func(message Message) error + type Header struct + Key string + Value []byte + func HeaderFromKafka(item kafka.Header) Header + func HeadersFromKafka(items []kafka.Header) (values []Header) + type Message struct + Headers []Header + HighWaterMark int64 + Key []byte + Offset int64 + Partition int + Time time.Time + Topic string + Value []byte + func MessageFromKafka(item kafka.Message) Message + type Streaming interface + Consumer func(ctx context.Context, topic string, handler ConsumerHandler) (err error) + Producer func(ctx context.Context, topic string, value []byte) (err error) + func NewKafka(network string, brokers []string) (Streaming, error)
Go to main page