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?