We are using a back version of spark (0.8.1) that depends on a customized version of kafka 0.7.2-spark. Where are the sources for it - either svn/github or simply the sources..jar
For reference here is the maven repo location for the binaries: https://repository.cloudera.com/artifactory/repo/org/apache/kafka/kafka/0.7.2-spark/ Index of repo/org/apache/kafka/kafka/0.7.2-spark Name Last modified Size ------------------------------ ../ <https://repository.cloudera.com/artifactory/repo/org/apache/kafka/kafka/>kafka-0.7.2-spark.jar <https://repository.cloudera.com/artifactory/repo/org/apache/kafka/kafka/0.7.2-spark/kafka-0.7.2-spark.jar> 22-Nov-2013 01:21 1.30 MBkafka-0.7.2-spark.jar.md5 <https://repository.cloudera.com/artifactory/repo/org/apache/kafka/kafka/0.7.2-spark/kafka-0.7.2-spark.jar.md5> 22-Nov-2013 01:21 32 byteskafka-0.7.2-spark.jar.sha1 <https://repository.cloudera.com/artifactory/repo/org/apache/kafka/kafka/0.7.2-spark/kafka-0.7.2-spark.jar.sha1> 22-Nov-2013 01:21 40 byteskafka-0.7.2-spark.pom <https://repository.cloudera.com/artifactory/repo/org/apache/kafka/kafka/0.7.2-spark/kafka-0.7.2-spark.pom> 22-Nov-2013 01:21 459 byteskafka-0.7.2-spark.pom.md5 <https://repository.cloudera.com/artifactory/repo/org/apache/kafka/kafka/0.7.2-spark/kafka-0.7.2-spark.pom.md5> 22-Nov-2013 01:21 32 byteskafka-0.7.2-spark.pom.sha1 <https://repository.cloudera.com/artifactory/repo/org/apache/kafka/kafka/0.7.2-spark/kafka-0.7.2-spark.pom.sha1> 22-Nov-2013 01:21 40 bytes ------------------------------ Artifactory Online Server at repository.cloudera.com Port 80
