root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

kafka-1278; More flexible helper scripts; patched by Nathan Brown; reviewed by Jun Rao

This commit is contained in:
Nathan Brown 2014-02-25 09:37:15 -08:00 committed by Jun Rao
parent 00afb619cb
commit edbed2823f
8 changed files with 39 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
bin/kafka-console-consumer.sh
View File

@ -14,5 +14,8 @@
# See the License for the specific language governing permissions and # See the License for the specific language governing permissions and
# limitations under the License. # limitations under the License.
export KAFKA_HEAP_OPTS="-Xmx512M" if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
export KAFKA_HEAP_OPTS="-Xmx512M"
fi
exec $(dirname $0)/kafka-run-class.sh kafka.consumer.ConsoleConsumer $@ exec $(dirname $0)/kafka-run-class.sh kafka.consumer.ConsoleConsumer $@

4
bin/kafka-console-producer.sh
View File

@ -14,5 +14,7 @@
# See the License for the specific language governing permissions and # See the License for the specific language governing permissions and
# limitations under the License. # limitations under the License.
export KAFKA_HEAP_OPTS="-Xmx512M" if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
export KAFKA_HEAP_OPTS="-Xmx512M"
fi
exec $(dirname $0)/kafka-run-class.sh kafka.producer.ConsoleProducer $@ exec $(dirname $0)/kafka-run-class.sh kafka.producer.ConsoleProducer $@

4
bin/kafka-consumer-perf-test.sh
View File

@ -14,5 +14,7 @@
# See the License for the specific language governing permissions and # See the License for the specific language governing permissions and
# limitations under the License. # limitations under the License.
export KAFKA_HEAP_OPTS="-Xmx512M" if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
export KAFKA_HEAP_OPTS="-Xmx512M"
fi
exec $(dirname $0)/kafka-run-class.sh kafka.perf.ConsumerPerformance $@ exec $(dirname $0)/kafka-run-class.sh kafka.perf.ConsumerPerformance $@

4
bin/kafka-producer-perf-test.sh
View File

@ -14,5 +14,7 @@
# See the License for the specific language governing permissions and # See the License for the specific language governing permissions and
# limitations under the License. # limitations under the License.
export KAFKA_HEAP_OPTS="-Xmx512M" if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
export KAFKA_HEAP_OPTS="-Xmx512M"
fi
exec $(dirname $0)/kafka-run-class.sh kafka.perf.ProducerPerformance $@ exec $(dirname $0)/kafka-run-class.sh kafka.perf.ProducerPerformance $@

9
bin/kafka-run-class.sh
View File

@ -23,9 +23,12 @@ fi
base_dir=$(dirname $0)/.. base_dir=$(dirname $0)/..
# create logs directory # create logs directory
LOG_DIR=$base_dir/logs if [ "x$LOG_DIR" = "x" ]; then
if [ ! -d $LOG_DIR ]; then LOG_DIR="$base_dir/logs"
mkdir $LOG_DIR fi
if [ ! -d "$LOG_DIR" ]; then
mkdir -p "$LOG_DIR"
fi fi
if [ -z "$SCALA_VERSION" ]; then if [ -z "$SCALA_VERSION" ]; then

10
bin/kafka-server-start.sh
View File

@ -20,8 +20,14 @@ then
exit 1 exit 1
fi fi
base_dir=$(dirname $0) base_dir=$(dirname $0)
export KAFKA_LOG4J_OPTS="-Dlog4j.configuration=file:$base_dir/../config/log4j.properties"
export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G" if [ "x$KAFKA_LOG4J_OPTS" = "x" ]; then
export KAFKA_LOG4J_OPTS="-Dlog4j.configuration=file:$base_dir/../config/log4j.properties"
fi
if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
export KAFKA_HEAP_OPTS="-Xmx1G -Xms1G"
fi
EXTRA_ARGS="-name kafkaServer -loggc" EXTRA_ARGS="-name kafkaServer -loggc"

5
bin/kafka-simple-consumer-perf-test.sh
View File

@ -14,5 +14,8 @@
# See the License for the specific language governing permissions and # See the License for the specific language governing permissions and
# limitations under the License. # limitations under the License.
export KAFKA_HEAP_OPTS="-Xmx512M" if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
export KAFKA_HEAP_OPTS="-Xmx512M -Xms512M"
fi
exec $(dirname $0)/kafka-run-class.sh kafka.perf.SimpleConsumerPerformance $@ exec $(dirname $0)/kafka-run-class.sh kafka.perf.SimpleConsumerPerformance $@

10
bin/zookeeper-server-start.sh
View File

@ -20,8 +20,14 @@ then
exit 1 exit 1
fi fi
base_dir=$(dirname $0) base_dir=$(dirname $0)
export KAFKA_LOG4J_OPTS="-Dlog4j.configuration=file:$base_dir/../config/log4j.properties"
export KAFKA_HEAP_OPTS="-Xmx512M -Xms512M" if [ "x$KAFKA_LOG4J_OPTS" = "x" ]; then
export KAFKA_LOG4J_OPTS="-Dlog4j.configuration=file:$base_dir/../config/log4j.properties"
fi
if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
export KAFKA_HEAP_OPTS="-Xmx512M -Xms512M"
fi
EXTRA_ARGS="-name zookeeper -loggc" EXTRA_ARGS="-name zookeeper -loggc"