Function NewConsumer

internal/queue/queue.go:38–40

NewConsumer creates a new Kafka consumer

(config *configs.Config, handler Handler)

// NewConsumer creates a new Kafka consumer
func NewConsumer(config *configs.Config, handler Handler) (Consumer, error) {
	return internal.NewConsumer(config, handler)
}