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()