If you look at ConsumerIterator, we will throw MessageSizeTooLargeException to the caller if the fetch size is too small.
Thanks, Jun On Wed, Jul 31, 2013 at 8:25 AM, Sam Meder <sam.me...@jivesoftware.com>wrote: > We're expecting to occasionally have to deal with pretty large messages > being sent to Kafka. We will of course set the fetch size appropriately > high, but are concerned about the behavior when the message exceeds the > fetch size. As far as I can tell the current behavior when a message that > is too large is encountered is to pretend it is not there and not notify > the consumer in any way. IMO it would be better to throw an exception than > silently ignoring the issue (with the current code one can't really > distinguish a large message from no data at all). > > Thoughts? > > /Sam
