NewConsumer return consumer message broker.

NewConsumerHandler return consumer handler.

NewProducer return message producer.

Config entity of kafka broker.

MessageDecoder decoder message data on topic.

Consumer represents a Sarama consumer consumer interface.

MessageEncoder message encoder publish message to kafka.

MessageProcessor contract message consumer processor.

Producer represents kafka publisher message topic.