Right now, this project is totally dependent on Kafka and it uses it in a non configurable way. It's a hidden blackbox.
The solution for that is splitting the project in 2 parts: the core and the Kafka connector.
Once it's achieved, it will be possible to develop new connectors to different technologies. It will also be possible to instantiate the connectors with custom options and use them in multiple ways.
Right now, this project is totally dependent on Kafka and it uses it in a non configurable way. It's a hidden blackbox.
The solution for that is splitting the project in 2 parts: the core and the Kafka connector.
Once it's achieved, it will be possible to develop new connectors to different technologies. It will also be possible to instantiate the connectors with custom options and use them in multiple ways.