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
I do not know why it is not described in official producers docs, but there is public producer flow simplifying committing consumed messages before publishing them - it is CommittableSink.
Possible worth it to implement that, pretty simple one because is completely based on existing FlexiFlow.
The text was updated successfully, but these errors were encountered:
I do not know why it is not described in official producers docs, but there is public producer flow simplifying committing consumed messages before publishing them - it is
CommittableSink
.Possible worth it to implement that, pretty simple one because is completely based on existing
FlexiFlow
.The text was updated successfully, but these errors were encountered: