code: func Mock(t *testing.T) *KafkaMock {
  	asyncP, aMock := client.GetAsyncProducerMock(t)
  	syncP, sMock := client.GetSyncProducerMock(t)
  	producers := multiplexerProducers{
  		syncP, syncP, asyncP, asyncP,
  	}
  
  	return &KafkaMock{
  		NewMultiplexer(getMockConsumerFactory(t), producers, &client.Config{}, "name", logrus.DefaultLogger()),
  		aMock, sMock}
  }
docs: // Mock returns mock of Multiplexer that can be used for testing purposes.