[BUG] Files generated per topic have fluctuating size instead of `batchSize`

[alpreu]

Describe the bug
The current sink implementation uses one batchSize summing the number of records of all topics together. This results in fluctuating real 'batch' sizes for each topic.

Expected behavior
The batchSize should be the minimum amount of records that are flushed for a topic.