You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
This repository has been archived by the owner on Oct 23, 2023. It is now read-only.
Applications using the Kinesis client should gracefully shutdown. By this we mean completing the current batch (both in the actor and in the KPL), to minimise duplication of messages.
The Producer doesn't currently do anything special here, but it should.
This must be fully tested by asserting duplication of messages published to a stream over a number of shutdowns
The outcome here is to verify how much duplication of messages happens under normal an exception scenarios. Exception meaning adding/removing shards, shutting down a consumer/producer, etc. Document the outcome and raise any necessary stories required to address unacceptable duplication.
The text was updated successfully, but these errors were encountered:
markglh
changed the title
Kinesis Producer Shutdown Testing: Graceful Shutdown
Producer Shutdown Testing: Graceful Shutdown
May 30, 2017
Sign up for freeto subscribe to this conversation on GitHub.
Already have an account?
Sign in.
This should be tackled AFTER: #6 & #7
Applications using the Kinesis client should gracefully shutdown. By this we mean completing the current batch (both in the actor and in the KPL), to minimise duplication of messages.
The Producer doesn't currently do anything special here, but it should.
This must be fully tested by asserting duplication of messages published to a stream over a number of shutdowns
The outcome here is to verify how much duplication of messages happens under normal an exception scenarios. Exception meaning adding/removing shards, shutting down a consumer/producer, etc. Document the outcome and raise any necessary stories required to address unacceptable duplication.
The text was updated successfully, but these errors were encountered: