KAFKA-1328 New consumer APIs; reviewed by Jun Rao and Guozhang Wang