title: SCDF Stream Design & Custom Processor
body: <p>My current usecase is to receive HTTP Post message, validate it, transform into business object with interested fields (only) and push to nosql db.</p>
  <p>I have completed successful poc on http source and mongodb sink on cloud foundry.</p>
  <p>For request data validation &amp; transformation, I do not find any available processor so assuming I will have to write one (actually, two).</p>
  <p>Can a validation processor generate conditional output? Meaning,</p>
  <ul>
  <li>send valid data to queue for further processing (here, transformation)?</li>
  <li>send invalid data to log/error processing in mongodb sink?</li>
  </ul>
  <p>Or should I design my stream in a different way? Appreciate your guidence.</p>
  <p>Thanks</p>