Re: Indication in FetchResponse that fetch size is too small

2015-07-03 Thread Stevo Slavić
Thanks for heads up Joel! Kind regards, Stevo Slavic. On Thu, Jul 2, 2015 at 10:17 PM, Joel Koshy wrote: > A somewhat related request came up in another thread and I think it is > reasonable to provide this. However, there are already some indicators > that you can use: > - The consumer iterato

Re: Indication in FetchResponse that fetch size is too small

2015-07-02 Thread Joel Koshy
A somewhat related request came up in another thread and I think it is reasonable to provide this. However, there are already some indicators that you can use: - The consumer iterator throws a MessageSizeTooLargeException if it cannot extract any messages out of the next chunk. - If you are using

Indication in FetchResponse that fetch size is too small

2015-07-02 Thread Stevo Slavić
Hello Apache Kafka community, Couldn't broker return a special error code in FetchResponse for a given partition(s) where it detects that there was something to return/read from partition but actual FetchResponse contains no messages for that partition since fetch size in FetchRequest for that par