If you want to use EOS, you cannot use your own producer, but you need to use a "sink node" (via `addSink()` or `to()`).
For at-least-once, if you use sync-writes, you should still get at-least-once guarantees. -Matthias On 7/9/21 4:12 AM, Pushkar Deole wrote: > 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? >> >
