Re: How to deal with error code in FetchResponse

2013-10-23 Thread xingcan
I see. Thanks Neha. On Thursday, October 24, 2013, Neha Narkhede wrote: > That was one of the examples I gave that doesn't cover all cases. We have > admin tools that can move leader away selectively. In that case, the > partitions would have different error codes. > > Thanks, > Neha > > > On Wed

Re: How to deal with error code in FetchResponse

2013-10-23 Thread Neha Narkhede
That was one of the examples I gave that doesn't cover all cases. We have admin tools that can move leader away selectively. In that case, the partitions would have different error codes. Thanks, Neha On Wed, Oct 23, 2013 at 1:36 AM, xingcan wrote: > Neha, > > Thanks for your prompt reply. And

Re: How to deal with error code in FetchResponse

2013-10-23 Thread xingcan
Neha, Thanks for your prompt reply. And I got another two questions. As I wrote before, my mechanism is to add all partitions belonging to the same leader broker to a single request. And then send these requests one by one for each broker. Is this necessary? And if that, all topic and partitions i

Re: How to deal with error code in FetchResponse

2013-10-22 Thread Neha Narkhede
We need to return an error code per partition since your fetch request could've succeeded for some but not all partitions. For example, if one broker fails, some partitions might temporarily return a LeaderNotAvailable error code. So you have to go through the individual error codes to know which p

How to deal with error code in FetchResponse

2013-10-21 Thread xingcan
Hi, After migrating from 0.72 to 0.8, I still use SimpleConsumer to construct my own consumer. By FetchRequestBuilder, I add all partitions belonging to the same broker to a single request and get a FetchResponse for all these partitions. However, I find the error code in FetchResponse is a littl