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