Hi Colin, I see that both the interface "Record" and the implementation "DefaultRecord" being used in LogValidator.java are public interfaces/classes.
https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/common/record/Records.java and https://github.com/apache/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java So, it should be ok to use them. Let me know what you think. Thanks, Soumyajit On Fri, Apr 2, 2021 at 8:51 AM Colin McCabe <cmcc...@apache.org> wrote: > 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 > > >
