Allow to change the consumer class

[Taluu]

So that we can use a custom consumer instead. :}

It should be adding a configuration option, and mess with the consumer factory (adding a class path) + di extension.