Github user srdo commented on the issue: https://github.com/apache/storm/pull/2829 Even if we change the spout to emit all the fetched records in one `nextTuple` call, the number and size of records returned in a fetch is limited by the `max.poll.records` KafkaConsumer setting (500 by default), as well as the `fetch.max.bytes` setting (50MB by default).
---