Skip to content
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: remove cleanup function, separate batching and writing #2824

Merged
merged 1 commit into from
Mar 9, 2022

Conversation

hagerf
Copy link
Contributor

@hagerf hagerf commented Feb 7, 2022

…esisFlow

References #2814

@hagerf hagerf force-pushed the kinesisflow-context-cleanup branch from a85fb3d to da94002 Compare February 7, 2022 14:46
@ennru
Copy link
Member

ennru commented Feb 11, 2022

Ok, this reverts parts of #2815 and the user with needs for special handling will want to re-use the existing handlePutRecordsSuccess, right?

@hagerf
Copy link
Contributor Author

hagerf commented Feb 14, 2022

Ok, this reverts parts of #2815 and the user with needs for special handling will want to re-use the existing handlePutRecordsSuccess, right?

Yes, it does revert previous changes. And the user with needs for special batching or (more commonly) special handling of the messages can use either their own Success/Failure handling or just add a failure handling if the handlePutRecordsSuccess is enough for Success. In my own case I'm using my own handlers returning an (Either[KinesisFailedWrite, PutRecordsResultEntry], Ctx).

Copy link
Member

@ennru ennru left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM.

@ennru ennru added this to the 4.0.0 milestone Mar 9, 2022
@ennru ennru changed the title removing cleanup function, separating the batching and writing in Kin… Kinesis: remove cleanup function, separate batching and writing Mar 9, 2022
@ennru ennru merged commit 213a421 into akka:master Mar 9, 2022
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants