From cfa6a78c7c2529839d2f3cb1129098f2e552fd72 Mon Sep 17 00:00:00 2001 From: Arjun Satish Date: Tue, 21 Nov 2017 16:07:06 -0800 Subject: [PATCH] KAFKA-4115: Increasing the heap settings for Connect scripts Signed-off-by: Arjun Satish Author: Arjun Satish Reviewers: Randall Hauch , Ewen Cheslack-Postava Closes #4213 from wicknicks/KAFKA-4115 --- bin/connect-distributed.sh | 4 ++++ bin/connect-standalone.sh | 4 ++++ 2 files changed, 8 insertions(+) diff --git a/bin/connect-distributed.sh b/bin/connect-distributed.sh index 99cd27b4689..08fc57b9c51 100755 --- a/bin/connect-distributed.sh +++ b/bin/connect-distributed.sh @@ -26,6 +26,10 @@ if [ "x$KAFKA_LOG4J_OPTS" = "x" ]; then export KAFKA_LOG4J_OPTS="-Dlog4j.configuration=file:$base_dir/../config/connect-log4j.properties" fi +if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then + export KAFKA_HEAP_OPTS="-Xms256M -Xmx2G" +fi + EXTRA_ARGS=${EXTRA_ARGS-'-name connectDistributed'} COMMAND=$1 diff --git a/bin/connect-standalone.sh b/bin/connect-standalone.sh index 623562aab3f..931cc37c9a4 100755 --- a/bin/connect-standalone.sh +++ b/bin/connect-standalone.sh @@ -26,6 +26,10 @@ if [ "x$KAFKA_LOG4J_OPTS" = "x" ]; then export KAFKA_LOG4J_OPTS="-Dlog4j.configuration=file:$base_dir/../config/connect-log4j.properties" fi +if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then + export KAFKA_HEAP_OPTS="-Xms256M -Xmx2G" +fi + EXTRA_ARGS=${EXTRA_ARGS-'-name connectStandalone'} COMMAND=$1