A consumer API for Kafka 0.8.x that returns messages in batches and only commits offsets for successfully processed ones.