Overuse of traits especially for declaring some default values. API clean.

[codingvlad]

Hello, I open this issue after seeing the details of the rest of the implementation. The previous issue is kind of related to this issue. The code should be refactored a bit. As this project is a template for future projects the high level of the structure should reflect that. I propose a structure like:

• kafka

• cordinators (or managers)

to separate the messaging layer from the light business logic. After that, inside Kafka there should be a high-level API for Consumer, Producer. Inside these objects should be placed the detailed API like Consumer.actor, Consumer.source, Producer.actor, Producer.sink, Flow, FlowACK. etc. All the deatils of the implementation should be placed in those classes and methods to abstract everything an give the user the ability to write simple code like:
val actorConsumer = Consumer.actor[String, String](topic: Topic, destination: ActorRef)
val source = Consumer.source[String, String](topic: Topic)