Hi Yuanchi, There is no out-of-box unit tests provided by Samza. But there are some ways:
1) If you only want to test the logic in the Task class, normal unit tests will work. You can create a unit test that tests init(), process(), etc. 2) Create mock systems by implementing SystemAdmin, SystemConsumer, etc. You can refer to this one TestSystemStreamPartitionIterator <https://github.com/apache/samza/blob/master/samza-api/src/test/java/org/apache/samza/system/TestSystemStreamPartitionIterator.java> 3) bring up zookeeper, kafka in the unit test. Here is the reference TestStatefulTask <https://github.com/apache/samza/blob/master/samza-test/src/test/scala/org/apache/samza/test/integration/TestStatefulTask.scala> 4) run the job locally <http://samza.apache.org/learn/documentation/0.9/jobs/job-runner.html> by setting the job.factory.class <http://samza.apache.org/learn/documentation/0.9/jobs/configuration-table.html> . Usually, I think 1) and 4) are sufficient. Hope this helps. Thanks, Fang, Yan yanfang...@gmail.com On Wed, Apr 15, 2015 at 1:47 PM, Yuanchi Ning <yuan...@uber.com> wrote: > Hello Samza Team, > > This is Yuanchi Ning from Uber Data Engineering, Realtime Metrics, > Streaming Platform team. > > We are planning to use Samza to process the realtime data we have, and > thanks for developing such an awesome open source project. > > While I am building our streaming service using Samza, I am wondering is > there anyway to do unit tests for each Samza application Task instead of > integration test? Say, set up the mocker environment for feeding data into > MessageEnvelope or something similar? > > Thanks for your assistance. > > Best, > Yuanchi >
