NewServer return new mock server instance.

Broker is mock version of kafka's broker.

Consumer mocks kafka's consumer.

ProducedMessages represents all arguments used for single Produce method call.

Producer mocks kafka's producer.

Server is container for fake kafka server data.

Response is any kafka response as defined in kafka/proto package.

Middleware is function that is called for every incomming kafka message, before running default processing handler.