A kafka consumer impl. in scala