This repository has been archived by the owner on Oct 23, 2023. It is now read-only.
KinesisProducerActor: failed sends should be retried #50
Comments
3 tasks
Sign up for free
to subscribe to this conversation on GitHub.
Already have an account?
Sign in.
The current implementation of
KinesisProducerActorsends every message toKinesisProducer. A successful produced message results in aSendSuccessful, otherwise aSendFailedactor message.If a message can not be published, it would be great if sending the message can be retried a configurable number of times.
A related feature is available on the consumer side: failedMessageRetries
The text was updated successfully, but these errors were encountered: