-
Notifications
You must be signed in to change notification settings - Fork 21
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
Add WriteAcks as a result of the SyncWriter operations #280
Comments
PR published - #281 (for some reason it didn’t link automatically) |
This was made on purpose to keep sync interface simple and not to overload it with CompletableFutures. |
There is a slight issue. We need the blocking behavior of the internal writer queue that is provided by the |
Ok, I got your concerns. We need some time to consider |
@pnv1, let's return to this topic |
Problem
Currently, the
tech.ydb.topic.write.SyncWriter
interface does not provide any technical means for users to receive and analyze the results of theirsend(...)
operations. This lack of functionality can make it difficult for developers to ensure that their messages are being sent successfully and to troubleshoot any issues that may arise.Proposed solution
Propagate the results of
sendImpl(...).join()
to the user codeThe text was updated successfully, but these errors were encountered: