Dear all, there are some changes for KIP-614
https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=158866569 1) the interface RecordReader extends Configurable. 2) the input stream is removed from RecordReader#configure method 3) RecordReader#readRecords accept InputStream as argument, and the returned type is changed from single ProducerRecord to Iterator<ProducerRecord> Please take a look and then start to vote if you have free time. thanks. vote: https://lists.apache.org/thread/kjdtyfg5xytn60q0qvxhfopzmfp9tsxr
