Matthias, Do you have any inputs on above queries?
On Wed, Jun 30, 2021 at 7:15 PM Pushkar Deole <pdeole2...@gmail.com> wrote: > Hi, > > Our application uses kafka streams that reads from a source topic, does > processing on records and produces processed record on destination topic > through the use of external producer i.e. the producer created via kafka > producer API. > > Does this model still guarantee exactly once semantic or it won't? > > Currently we are using at_least_once, however the question is how streams > handles offset commits here? > Though the event is produced using synchronous API, could there be > possibility of event loss in case streams commit offset before external > producer hasn't produced event on destination topic yet? >
