Hi Team, Adding on top of this, I tried creating a TransactionContext object and calling the commitTransaction and abortTranaction methods in source connectors. But the main problem I saw is that if there is any error while parsing the record, connect is calling an abort but we have a use case to call commit in some cases. Is it a valid use case in terms of kafka connect?
Another Question - Should I use a transactional producer instead creating an object of TransactionContext? Below is the connector configuration I am using. exactly.once.support: "required" transaction.boundary: "connector" Could you please help me here? Thanks, Nitty On Tue, Mar 7, 2023 at 12:29 AM NITTY BENNY <nittybe...@gmail.com> wrote: > Hi Team, > I am trying to implement exactly once behavior in our source connector. Is > there any sample source connector implementation available to have a look > at? > Regards, > Nitty >
