kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: KAFKA-3872; Reduce log cleaner buffer size to 2 MB
Date Tue, 21 Jun 2016 20:52:02 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk d546aa292 -> 8b7dce87a


KAFKA-3872; Reduce log cleaner buffer size to 2 MB

Author: Eno Thereska <eno.thereska@gmail.com>

Reviewers: Guozhang Wang <wangguoz@gmail.com>, Ismael Juma <ismael@juma.me.uk>

Closes #1533 from enothereska/KAFKA-3872-oom-integration-tests


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

Branch: refs/heads/trunk
Commit: 8b7dce87a744837e5b3bba41b3e3c4c408c78b7f
Parents: d546aa2
Author: Eno Thereska <eno.thereska@gmail.com>
Authored: Tue Jun 21 22:35:01 2016 +0200
Committer: Ismael Juma <ismael@juma.me.uk>
Committed: Tue Jun 21 22:35:01 2016 +0200

----------------------------------------------------------------------
 .../streams/integration/utils/EmbeddedSingleNodeKafkaCluster.java   | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/8b7dce87/streams/src/test/java/org/apache/kafka/streams/integration/utils/EmbeddedSingleNodeKafkaCluster.java
----------------------------------------------------------------------
diff --git a/streams/src/test/java/org/apache/kafka/streams/integration/utils/EmbeddedSingleNodeKafkaCluster.java
b/streams/src/test/java/org/apache/kafka/streams/integration/utils/EmbeddedSingleNodeKafkaCluster.java
index d3ba065..c2f58ee 100644
--- a/streams/src/test/java/org/apache/kafka/streams/integration/utils/EmbeddedSingleNodeKafkaCluster.java
+++ b/streams/src/test/java/org/apache/kafka/streams/integration/utils/EmbeddedSingleNodeKafkaCluster.java
@@ -49,6 +49,7 @@ public class EmbeddedSingleNodeKafkaCluster extends ExternalResource {
         brokerConfig.put(KafkaConfig$.MODULE$.ZkConnectProp(), zKConnectString());
         brokerConfig.put(KafkaConfig$.MODULE$.PortProp(), DEFAULT_BROKER_PORT);
         brokerConfig.put(KafkaConfig$.MODULE$.DeleteTopicEnableProp(), true);
+        brokerConfig.put(KafkaConfig$.MODULE$.LogCleanerDedupeBufferSizeProp(), 2 * 1024
* 1024L);
 
         log.debug("Starting a Kafka instance on port {} ...", brokerConfig.getProperty(KafkaConfig$.MODULE$.PortProp()));
         broker = new KafkaEmbedded(brokerConfig);


Mime
View raw message