Just tried #3. Changed the property file wikipedia-feed.properties job.factory.class=org.apache.samza.job.local.LocalJobFactory Ran ..
deploy/samza/bin/run-job.sh --config-factory=org.apache.samza.config.factories.PropertiesConfigFactory --config-path=file:///home/ctippur/hello-samza/deploy/samza/config/wikipedia-feed.properties I dont see any debug messages that I added to the feed or the parser file.. I see messages on the kafka-consumer .. However the feed job died with the below message Exception in thread "ThreadJob" java.lang.RuntimeException: Trying to unlisten to a channel that has no listeners in it. at samza.examples.wikipedia.system.WikipediaFeed.unlisten(WikipediaFeed.java:98) at samza.examples.wikipedia.system.WikipediaConsumer.stop(WikipediaConsumer.java:72) at org.apache.samza.system.SystemConsumers$$anonfun$stop$2.apply(SystemConsumers.scala:152) at org.apache.samza.system.SystemConsumers$$anonfun$stop$2.apply(SystemConsumers.scala:152) at scala.collection.Iterator$class.foreach(Iterator.scala:727) at scala.collection.AbstractIterator.foreach(Iterator.scala:1157) at scala.collection.MapLike$DefaultValuesIterable.foreach(MapLike.scala:206) at org.apache.samza.system.SystemConsumers.stop(SystemConsumers.scala:152) at org.apache.samza.container.SamzaContainer.shutdownConsumers(SamzaContainer.scala:587) at org.apache.samza.container.SamzaContainer.run(SamzaContainer.scala:512) at org.apache.samza.job.local.ThreadJob$$anon$1.run(ThreadJob.scala:42) - Shekar
