How to Use samza-hdfs

I'm using samza-hdfs to write Kafka streams to HDFS, but I can't make it work. Here is my samza job's properties file: # Job job.factory.class=org.apache.samza.job.yarn.YarnJobFactory job.name=kafka2hdfs # YARN yarn.package.path=file://${basedir}/target/${project.artifactId}-${pom.version}-dist.

[GitHub] samza pull request #34: SAMZA-1031 : Use Java 1.8 source compatibility for S...

GitHub user shanthoosh opened a pull request: https://github.com/apache/samza/pull/34 SAMZA-1031 : Use Java 1.8 source compatibility for Samza Java 7 will be no longer supported. You can merge this pull request into a Git repository by running: $ git pull https://github.com/sh

[GitHub] samza pull request #33: SAMZA-855 - Upgrade Samza's Kafka client version to ...

GitHub user shanthoosh opened a pull request: https://github.com/apache/samza/pull/33 SAMZA-855 - Upgrade Samza's Kafka client version to 0.10.0.1. This is based out of PR 15, with merge conflicts resolved and version number of zkClient set to 0.8(compatible with Kafka 0.0.10.1 vers