4. Define streaming operations

[dagmendez]

Include some trivial logic that will apply certain transformation to the data from kakfa-consumer.

This trivial logic can be, for example, some filtering and grouping. Test that it work by saving the result to some local file or printing it to the console.

[dagmendez]

Since the event in the topic from data-generator are Array[Byte], this issue will include the development / usage of encoder and decoders to work with the data. They can be potentially reused from other parts of the code.