Versions in this module Expand all Collapse all v1 v1.1.0 Jul 24, 2021 v1.0.0 May 10, 2021 Changes in this version + type Options struct + Brokers []string + GroupID string + KafkaVersion string + type Queue struct + func New(opts Options) *Queue + func (q *Queue) Cleanup(sarama.ConsumerGroupSession) error + func (q *Queue) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error + func (q *Queue) Run() + func (q *Queue) Setup(sarama.ConsumerGroupSession) error
Go to main page