It looks like the new consumer API expects developers to manage the failures? Or is there some other API that can abstract the failures, primarily:
1) Automatically resent failed messages because of network issue or some other issue between the broker and the consumer 2) Ability to acknowledge receipt of a message by the consumer such that message is sent again if consumer fails to acknowledge the receipt. Is there such an API or are the clients expected to deal with failure scenarios? Docs I am looking at are here: http://people.apache.org/~nehanarkhede/kafka-0.9-consumer-javadoc/doc/
