-
Notifications
You must be signed in to change notification settings - Fork 648
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Kinesis push throughput (maxBytesPerSecond) throttling ineffective #2871
Labels
Comments
Unit test
|
mberchon
changed the title
Kinesis push throughput throttling ineffective
Kinesis push throughput (maxBytesPerSecond) throttling ineffective
May 30, 2022
My work around: add throughput throttle flow on the upstream with the following weight function
|
@ennru I think this can be closed |
Thank you for your effort! |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Versions used
Expected Behavior
KinesisFlow should be throttled to 1 MBs per shard whatever the factory methods used to create the ByteBuffer payload.
Actual Behavior
Flow throughput is unlimited
Relevant logs
akka.stream.alpakka.kinesis.scaladsl.KinesisFlow line 72
request.data.asByteBuffer.position() returns 0 if data created from array wrapping
software.amazon.awssdk.core.BytesWrapper line 55
The text was updated successfully, but these errors were encountered: