nleena123 commented on issue #5540: URL: https://github.com/apache/hudi/issues/5540#issuecomment-1125761522
yes , below DFAvroKafkaSource.java file we are using to read the data which extends AvroSource. DF3HoodieDeltaStreamer.java which extends HoodieDeltaStreamer , and attached pom.xml file [code.zip](https://github.com/apache/hudi/files/8685199/code.zip) in the folder please have a look on it and let me know ,if any changes required in my code . -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
