Change KafkaConsumer loop to consume all message sets (#80)
Change KafkaConsumer loop to consume all message sets (#80)

* Change KafkaConsumer loop to consume all message sets

Change-Id: I232fa97a0136f32305f23b6510282288e5fcbd48

* Run rustfmt and change use std::{self} to just use std

Change-Id: I5bfaf01ba30d6acd53648e66d1c1603accea12ff

sevagh/pqrs,sevagh/pqrs,sevagh/pq,sevagh/pq