Open dagmendez opened 1 year ago
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.
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.