The current implementation is a copy & paste from the original PoC, without any type of testing. It is necessary to write an integrations test, starting up a real cluster before the test, using sbt.