A polling consumer API for Kafka 0.8.* that only commits offsets for successfully processed messages