Hi,My requirement has been captured by the following stack overflow question. https://stackoverflow.com/questions/61876849/custom-kafka-source-on-apache-flinkCould anyone take a shot at it ?Thanks,Prasanna.