Substation uses the internal/aggregate package to buffer events with consideration to buffer size, record counts, and durations which shadow the checks here with adherence to Kinesis limits in a more user friendly way.
Motivation and Context
Inclusion of the size checks here allowed events between 25KiB and 1MiB to be sent as empty events to destinations.
How Has This Been Tested?
The fix has been tested on the internal pipeline containing events ranging from 10KiB to 1MiB with no issues.
Types of changes
[x] Bug fix (non-breaking change which fixes an issue)
[ ] New feature (non-breaking change which adds functionality)
[ ] Breaking change (fix or feature that would cause existing functionality to change)
Checklist:
[x] My code follows the code style of this project.
[ ] My change requires a change to the documentation.
Description
Substation uses the
internal/aggregatepackage to buffer events with consideration to buffer size, record counts, and durations which shadow the checks here with adherence to Kinesis limits in a more user friendly way.Motivation and Context
Inclusion of the size checks here allowed events between 25KiB and 1MiB to be sent as empty events to destinations.
How Has This Been Tested?
The fix has been tested on the internal pipeline containing events ranging from 10KiB to 1MiB with no issues.
Types of changes
Checklist: