Files
David Arthur f67ad27f72 Auto-adjusting consumer fetch size
Related to #42

Adds new ConsumerFetchSizeTooSmall exception that is thrown when
`_decode_message_set_iter` gets a BufferUnderflowError but has not yet
yielded a message

In this event, SimpleConsumer will increase the fetch size by 1.5 and
continue the fetching loop while _not_ increasing the offset (basically
just retries the request with a larger fetch size)

Once the consumer fetch size has been increased, it will remain
increased while SimpleConsumer fetches from that partition
2013-09-09 00:47:28 -04:00
..
2012-10-02 12:09:19 -04:00
2013-06-07 21:20:55 -04:00