core.Mechanisms

This is what we get back after init

KafkaAvro.init(Settings).then( Mechanisms => {
    // ..
} , error => {
  // ..
});

`Mechanisms.schemas`

This is the schema pool

Send a message to a topic

Mechanisms.send = function(){
  // logic
};

Create a new consumer

Mechanisms.addConsumer = function(){
  // logic
};

Create a new producer

Mechanisms.addProducer = function(){
  // logic
};