Consumer picking up records less than that mentioned in limit

[albin-joseph-101]

The consumer seems to be picking up much less records than the limit passed to it in the constructor even though the stream has much more records than that. I am not able to triangulate the issue.

in record processing I'm performing async operations which waits for completion before picking up the next batch of records