You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by jk...@apache.org on 2014/02/19 04:32:05 UTC

git commit: Fix compile issue from last commit. Oops. :-(

Repository: kafka
Updated Branches:
  refs/heads/trunk 3f0b67b6a -> 22f76d8b3


Fix compile issue from last commit. Oops. :-(


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/22f76d8b
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/22f76d8b
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/22f76d8b

Branch: refs/heads/trunk
Commit: 22f76d8b362417858e61f0f9a2fc80d620790f2f
Parents: 3f0b67b
Author: Jay Kreps <ja...@gmail.com>
Authored: Tue Feb 18 19:31:30 2014 -0800
Committer: Jay Kreps <ja...@gmail.com>
Committed: Tue Feb 18 19:31:30 2014 -0800

----------------------------------------------------------------------
 core/src/main/scala/kafka/tools/newproducer/MirrorMaker.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/22f76d8b/core/src/main/scala/kafka/tools/newproducer/MirrorMaker.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/tools/newproducer/MirrorMaker.scala b/core/src/main/scala/kafka/tools/newproducer/MirrorMaker.scala
index 0d6d702..d23ef9a 100644
--- a/core/src/main/scala/kafka/tools/newproducer/MirrorMaker.scala
+++ b/core/src/main/scala/kafka/tools/newproducer/MirrorMaker.scala
@@ -84,7 +84,7 @@ object MirrorMaker extends Logging {
       new Blacklist(options.valueOf(blacklistOpt))
     val producerConfig = options.valueOf(producerConfigOpt)
     val producerProps = Utils.loadProps(producerConfig)
-    producerProps.setProperty(ProducerConfig.BLOCK_ON_BUFFER_FULL, "true")
+    producerProps.setProperty(ProducerConfig.BLOCK_ON_BUFFER_FULL_CONFIG, "true")
     val consumerConfig = options.valueOf(consumerConfigOpt)
     val numStreams = options.valueOf(numStreamsOpt)
     producerChannel = new ProducerDataChannel()