kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject svn commit: r1342487 - in /incubator/kafka/branches/0.8: core/lib/zkclient-20120522.jar project/build/KafkaProject.scala
Date Fri, 25 May 2012 01:49:22 GMT
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
 



Mime
View raw message