/Samza-Job

Running a samza job to read input messages from one kafka topic and push it to another kafka output topic.

Primary LanguageShell

Samza Job

To run the job:

  • Create kafka topics: "telemetry-sample" and "telemetry-sample1". Push some string messages into "telemetry-sample".
  • In the deploy folder run the following command:

bin/run-job.sh --config-factory=org.apache.samza.config.factories.PropertiesConfigFactory --config-path=config/samzajob.properties