It takes two kafka input topics namely, ExampleInputStream1 and ExampleInputStream2. And merge their data to one output topic namely, ExampleOutputStream.
Currently having trouble to set up the TaskFactory thing in ExampleTaskApplication.scala file. And unable to work with yarn.