Function MockKafkaConsumerFunc

testing/utils.go:54–59

(brokers []string)

}

func MockKafkaConsumerFunc(brokers []string) (sarama.Consumer, error) {
	var t GinkgoTestReporter
	config := sarama.NewConfig()
	config.ChannelBufferSize = 2 * 5000
	return mocks.NewConsumer(t, config), nil
}