consumer

Documentation

Index

• Variables
• func CreateConsumerGroup(brokers []string, config *sarama.Config, groupId string) (sarama.ConsumerGroup, metrics.Registry, error)

Variables

var NewConsumerGroupWrapper = func(brokers []string, groupId string, config *sarama.Config) (sarama.ConsumerGroup, error) {
	return sarama.NewConsumerGroup(brokers, groupId, config)
}

Function Reference Variable To Facilitate Mocking In Unit Tests

Functions

func CreateConsumerGroup

func CreateConsumerGroup(brokers []string, config *sarama.Config, groupId string) (sarama.ConsumerGroup, metrics.Registry, error)

Create A Kafka ConsumerGroup (Optional SASL Authentication)