Fwd: Exactly once kafka connect query

2023-03-07 Thread NITTY BENNY
Hi Chrise, Thanks for sharing the details. Regarding the use case, For Asn1 source connector we have a use case to validate number of records in the file with the number of records in the header. So currently, if validation fails we are not sending the last record to the topic. But after introduc

Fwd: Exactly once kafka connect query

2023-03-07 Thread NITTY BENNY
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