kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jkr...@apache.org
Subject git commit: Fix compile issue from last commit. Oops. :-(
Date Wed, 19 Feb 2014 03:32:05 GMT
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 <jay.kreps@gmail.com>
Authored: Tue Feb 18 19:31:30 2014 -0800
Committer: Jay Kreps <jay.kreps@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()


Mime
View raw message