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 >>
