Index: core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala
===================================================================
--- core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala	(revision 1244751)
+++ core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala	(working copy)
@@ -384,7 +384,7 @@
             lock.lock()
             try {
               if (!isWatcherTriggered)
-                cond.wait()
+                cond.await()
             } finally {
               isWatcherTriggered = false
               lock.unlock()