You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2012/05/25 03:49:22 UTC
svn commit: r1342487 - in /incubator/kafka/branches/0.8:
core/lib/zkclient-20120522.jar project/build/KafkaProject.scala
Author: junrao
Date: Fri May 25 01:49:22 2012
New Revision: 1342487
URL: http://svn.apache.org/viewvc?rev=1342487&view=rev
Log:
upgrade ZKClient to allow conditional updates in ZK; patched by Jun Rao; reviewed by Joel Koshy; KAFKA-337
Added:
incubator/kafka/branches/0.8/core/lib/zkclient-20120522.jar (with props)
Modified:
incubator/kafka/branches/0.8/project/build/KafkaProject.scala
Added: incubator/kafka/branches/0.8/core/lib/zkclient-20120522.jar
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/core/lib/zkclient-20120522.jar?rev=1342487&view=auto
==============================================================================
Binary file - no diff available.
Propchange: incubator/kafka/branches/0.8/core/lib/zkclient-20120522.jar
------------------------------------------------------------------------------
svn:mime-type = application/octet-stream
Modified: incubator/kafka/branches/0.8/project/build/KafkaProject.scala
URL: http://svn.apache.org/viewvc/incubator/kafka/branches/0.8/project/build/KafkaProject.scala?rev=1342487&r1=1342486&r2=1342487&view=diff
==============================================================================
--- incubator/kafka/branches/0.8/project/build/KafkaProject.scala (original)
+++ incubator/kafka/branches/0.8/project/build/KafkaProject.scala Fri May 25 01:49:22 2012
@@ -56,10 +56,29 @@ class KafkaProject(info: ProjectInfo) ex
<exclude module="log4j"/>
<exclude module="jline"/>
</dependency>
- <dependency org="com.github.sgroschupf" name="zkclient" rev="0.1">
- </dependency>
</dependencies>
+ def zkClientDep =
+ <dependency>
+ <groupId>zkclient</groupId>
+ <artifactId>zkclient</artifactId>
+ <version>20120522</version>
+ <scope>compile</scope>
+ </dependency>
+
+ object ZkClientDepAdder extends RuleTransformer(new RewriteRule() {
+ override def transform(node: Node): Seq[Node] = node match {
+ case Elem(prefix, "dependencies", attribs, scope, deps @ _*) => {
+ Elem(prefix, "dependencies", attribs, scope, deps ++ zkClientDep :_*)
+ }
+ case other => other
+ }
+ })
+
+ override def pomPostProcess(pom: Node): Node = {
+ ZkClientDepAdder(pom)
+ }
+
override def artifactID = "kafka"
override def filterScalaJars = false