Versions in this module Expand all Collapse all v0 v0.1.1 Feb 20, 2020 v0.1.0 Feb 19, 2020 Changes in this version + type Consumer struct + TopicPrefix string + func NewConsumer(cfg *kafka.ReaderConfig) *Consumer + func (c Consumer) Close() error + func (c Consumer) Consume(mh qrpc.MessageHandler) error + func (c Consumer) Subscribe(queues []string) error + type Producer struct + func NewProducer(cfg *kafka.WriterConfig) *Producer + func (p Producer) Close() error + func (p Producer) Produce(ctx context.Context, msg qrpc.Message) error + func (p Producer) SetQueue(queue string) + type Reader interface + Close func() error + CommitMessages func(ctx context.Context, msgs ...kafka.Message) error + FetchMessage func(ctx context.Context) (kafka.Message, error) + Init func(cfg *kafka.ReaderConfig) + type Writer interface + Close func() error + Init func(cfg *kafka.WriterConfig) + WriteMessages func(ctx context.Context, msgs ...kafka.Message) error
Go to main page