code: func GetConsumerMock(t mocks.ErrorReporter) *Consumer {
  	cfg := NewConfig(logrus.DefaultLogger())
  	ap := Consumer{
  		Logger:       logrus.DefaultLogger(),
  		Config:       cfg,
  		Consumer:     newClusterConsumerMock(t),
  		closeChannel: make(chan struct{}),
  	}
  
  	return &ap
  }
docs: // GetConsumerMock returns mocked implementation of consumer that doesn't need connection
  // to kafka cluster.