You can set
job.factory.class=org.apache.samza.job.local.ThreadJobFactory
samza property in config file and debug the job in IDE.
Vadym.
On Wed, Mar 9, 2016 at 3:47 AM, Robert Zuljevic
wrote:
> Hi all,
>
>
>
> We would like to write and run integration tests for our own Samza
> Tasks/Jobs, but
Hi all,
We would like to write and run integration tests for our own Samza Tasks/Jobs,
but without using external tools like Zoopkio, but rather as a part of the
build process. What we would like to do is start Yarn/Zookeeper/Kafka locally
(or in a docker container) and then submit jobs program
