We need to separate kafka client related code as an independent module so that we can easily test the behaviours.
It is also needed to find an easy way to set-up testing environments and run tests with/without kafka broker running.
[x] Configure and build kafka clients
[ ] Copy+paste kafka client part to the daemon routine.
[ ] Build test helper/environment and document them
We need to separate kafka client related code as an independent module so that we can easily test the behaviours. It is also needed to find an easy way to set-up testing environments and run tests with/without kafka broker running.