-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/20697/
-----------------------------------------------------------

Review request for samza.


Repository: samza


Description
-------

Fail early when a consumer is misconfigured.

1. wraped the consumer register with try and catch
2. added SystemConsumerException extends SamzaException
3. added test for checking throwing the correct exception


Diffs
-----

  samza-core/src/main/scala/org/apache/samza/system/SystemConsumers.scala 
7624aef 
  samza-core/src/test/scala/org/apache/samza/system/TestSystemConsumers.scala 
e1b211d 

Diff: https://reviews.apache.org/r/20697/diff/


Testing
-------


Thanks,

Yan Fang

Reply via email to