nathanmarz/storm-kestrel — pull request #8 by ronniekk (2012-10-17 06:44:33+00:00)
Title: Configurable Kestrel batch_size 

This patch makes it possible to specify the batch_size used by the Kestrel Thrift client by adding a new constructor:

public KestrelThriftSpout(List hosts, int port, String queueName, Scheme scheme, int batchSize)

Its current hard-coded value of 4000 is not suitable for a Kestrel queue with fairly large (~1MB) objects and easily causes OOM errors.