Can I get a link to other type of examples? I would like to see how to write the API code correctly.
On Fri, Oct 23, 2015 at 8:23 AM, Gwen Shapira <g...@confluent.io> wrote: > There are some examples that include error handling. These are to > demonstrate the new and awesome seek() method. > You don't have to handle errors that way, we are just showing that you can. > > On Thu, Oct 22, 2015 at 8:34 PM, Mohit Anchlia <mohitanch...@gmail.com> > wrote: > > 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 > >> >
