It's in this link. Most of the examples have some kind of error handling http://people.apache.org/~nehanarkhede/kafka-0.9-consumer-javadoc/doc/
On Thu, Oct 22, 2015 at 7:45 PM, Guozhang Wang <wangg...@gmail.com> wrote: > Could you point me to the exact examples that indicate user error handling? > > Guozhang > > On Thu, Oct 22, 2015 at 5:43 PM, Mohit Anchlia <mohitanch...@gmail.com> > wrote: > > > The examples in the javadoc seems to imply that developers need to manage > > all of the aspects around failures. Those examples are for rewinding > > offsets, dealing with failed portioned for instance. > > > > On Thu, Oct 22, 2015 at 11:17 AM, Guozhang Wang <wangg...@gmail.com> > > wrote: > > > > > Hi Mohit: > > > > > > In general new consumers will abstract developers from any network > > > failures. More specifically. > > > > > > 1) consumers will automatically try to re-fetch the messages if the > > > previous fetch has failed. > > > 2) consumers will remember the currently fetch positions after each > > > successful fetch, and can periodically commit these offsets back to > > Kafka. > > > > > > Guozhang > > > > > > On Thu, Oct 22, 2015 at 10:11 AM, Mohit Anchlia < > mohitanch...@gmail.com> > > > wrote: > > > > > > > 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/ > > > > > > > > > > > > > > > > -- > > > -- Guozhang > > > > > > > > > -- > -- Guozhang >
