Repository: kafka Updated Branches: refs/heads/trunk d546aa292 -> 8b7dce87a
KAFKA-3872; Reduce log cleaner buffer size to 2 MB Author: Eno Thereska <[email protected]> Reviewers: Guozhang Wang <[email protected]>, Ismael Juma <[email protected]> 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 <[email protected]> Authored: Tue Jun 21 22:35:01 2016 +0200 Committer: Ismael Juma <[email protected]> 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);
