Use one consumer thread per requested Kafka stream.

Also reduce the default threads for the input from 10 to 2.

Before this, there was a thread pool with a hardcoded size of 5 which
caused problems if the input thread size was bigger.

This might help #603 and #540.