Hi Team, I have a query regarding the KafkaDeserializerExtractor. May I've missed something, but there's no out-of-the-box API provided to read the records from Kafka *one-by-one*.
I could only see *readRecordImpl* (KafkaExtractor) which inherently uses a *messageIterator* (access modifier is private). Our use is that we wanted to leverage the WorkUnits genrated by Gobblin and do some of our own custom processing / calculation on the records being read. Any advise or guidance would be greatly appreciated!!! Thanks, Prateek Gupta
