Hi Soumyajit, I believe we've had discussions about proposals similar to this before, although I'm having trouble finding one right now. The issue here is that Record is a private class -- it is not part of any public API, and may change at any time. So we can't expose it in public APIs.
best, Colin On Thu, Apr 1, 2021, at 14:18, Soumyajit Sahu wrote: > Hello All, > I would like to start a discussion on the KIP-729. > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-729%3A+Custom+validation+of+records+on+the+broker+prior+to+log+append > > Thanks! > Soumyajit >