Skip to content
This repository has been archived by the owner on Mar 30, 2021. It is now read-only.

Check buffer after each record is added #75

Open
wants to merge 1 commit into
base: master
Choose a base branch
from

Conversation

jbeemster
Copy link

When GetRecords is called it does not appear to adhere to the buffer limits that have been put in place. This results in Buffers which can in some cases far exceed what is safe for an emitter to actually send.

This results in either the need to re-split the buffer within the Emitter to ensure that the buffer size is within a manageable range or simply resulting in the emitter failing to push the Buffer to its target due to size constraints of the sink.

This ensures that the buffer is not overfilled
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

1 participant