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 <[email protected]> Authored: Tue Feb 18 19:31:30 2014 -0800 Committer: Jay Kreps <[email protected]> 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()
