[FLINK-1160] Method added to RecordReaders to allow publishing events to specific inputs