The goal is to duplicate the nuxeo-importer-queues module and make it work with Kafka queues instead of Java in memory queuing.
This should handle correctly :
- multi-threaded consumer
- pluggable policy for dispatching data across different topics
We should then be able to run a benchmark test using a variation of the RandomTextGenerator just to verify that the system does scale