Repository: kafka
Updated Branches:
refs/heads/trunk 35f589bb4 -> b77099626
kafka-1700; examples directory - README and shell scripts are out of date; patched by Geoffrey
Anderson; reviewed by Jun Rao
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/b7709962
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/b7709962
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/b7709962
Branch: refs/heads/trunk
Commit: b77099626e8fc258abed67dc10b2816347ba0f2b
Parents: 35f589b
Author: Geoffrey Anderson <granders@gmail.com>
Authored: Thu Oct 23 16:12:20 2014 -0700
Committer: Jun Rao <junrao@gmail.com>
Committed: Thu Oct 23 16:12:54 2014 -0700
----------------------------------------------------------------------
examples/README | 13 +------
examples/bin/java-producer-consumer-demo.sh | 43 ++----------------------
examples/bin/java-simple-consumer-demo.sh | 43 ++----------------------
3 files changed, 7 insertions(+), 92 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/b7709962/examples/README
----------------------------------------------------------------------
diff --git a/examples/README b/examples/README
index 61de286..53db696 100644
--- a/examples/README
+++ b/examples/README
@@ -1,17 +1,6 @@
This directory contains examples of client code that uses kafka.
-The default target for ant is kafka.examples.KafkaConsumerProducerDemo which sends and receives
-messages from Kafka server.
-
-In order to run demo from SBT:
- 1. Start Zookeeper and the Kafka server
- 2. ./sbt from top-level kafka directory
- 3. Switch to the kafka java examples project -> project kafka-examples
- 4. execute run -> run
- 5. For simple consumer demo, select option 1
- For unlimited producer-consumer run, select option 2
-
-To run the demo using scripts:
+To run the demo:
1. Start Zookeeper and the Kafka server
2. For simple consumer demo, run bin/java-simple-consumer-demo.sh
http://git-wip-us.apache.org/repos/asf/kafka/blob/b7709962/examples/bin/java-producer-consumer-demo.sh
----------------------------------------------------------------------
diff --git a/examples/bin/java-producer-consumer-demo.sh b/examples/bin/java-producer-consumer-demo.sh
index 29e01c2..fd25e59 100755
--- a/examples/bin/java-producer-consumer-demo.sh
+++ b/examples/bin/java-producer-consumer-demo.sh
@@ -16,44 +16,7 @@
base_dir=$(dirname $0)/../..
-for file in $base_dir/project/boot/scala-2.8.0/lib/*.jar;
-do
- if [ ${file##*/} != "sbt-launch.jar" ]; then
- CLASSPATH=$CLASSPATH:$file
- fi
-done
-
-for file in $base_dir/core/lib_managed/scala_2.8.0/compile/*.jar;
-do
- CLASSPATH=$CLASSPATH:$file
-done
-
-for file in $base_dir/core/lib/*.jar;
-do
- CLASSPATH=$CLASSPATH:$file
-done
-
-for file in $base_dir/core/target/scala_2.8.0/*.jar;
-do
- CLASSPATH=$CLASSPATH:$file
-done
-
-for file in $base_dir/examples/target/scala_2.8.0/*.jar;
-do
- CLASSPATH=$CLASSPATH:$file
-done
-
-echo $CLASSPATH
-
-if [ -z "$KAFKA_PERF_OPTS" ]; then
- KAFKA_OPTS="-Xmx512M -server -Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.port=3333
-Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.ssl=false"
-fi
-
-if [ -z "$JAVA_HOME" ]; then
- JAVA="java"
-else
- JAVA="$JAVA_HOME/bin/java"
+if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
+ export KAFKA_HEAP_OPTS="-Xmx512M"
fi
-
-$JAVA $KAFKA_OPTS -cp $CLASSPATH kafka.examples.KafkaConsumerProducerDemo $@
-
+exec $base_dir/bin/kafka-run-class.sh kafka.examples.KafkaConsumerProducerDemo $@
http://git-wip-us.apache.org/repos/asf/kafka/blob/b7709962/examples/bin/java-simple-consumer-demo.sh
----------------------------------------------------------------------
diff --git a/examples/bin/java-simple-consumer-demo.sh b/examples/bin/java-simple-consumer-demo.sh
index 4716a09..c4f103e 100755
--- a/examples/bin/java-simple-consumer-demo.sh
+++ b/examples/bin/java-simple-consumer-demo.sh
@@ -16,44 +16,7 @@
base_dir=$(dirname $0)/../..
-for file in $base_dir/project/boot/scala-2.8.0/lib/*.jar;
-do
- if [ ${file##*/} != "sbt-launch.jar" ]; then
- CLASSPATH=$CLASSPATH:$file
- fi
-done
-
-for file in $base_dir/core/lib_managed/scala_2.8.0/compile/*.jar;
-do
- CLASSPATH=$CLASSPATH:$file
-done
-
-for file in $base_dir/core/lib/*.jar;
-do
- CLASSPATH=$CLASSPATH:$file
-done
-
-for file in $base_dir/core/target/scala_2.8.0/*.jar;
-do
- CLASSPATH=$CLASSPATH:$file
-done
-
-for file in $base_dir/examples/target/scala_2.8.0/*.jar;
-do
- CLASSPATH=$CLASSPATH:$file
-done
-
-echo $CLASSPATH
-
-if [ -z "$KAFKA_PERF_OPTS" ]; then
- KAFKA_OPTS="-Xmx512M -server -Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.port=3333
-Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.ssl=false"
-fi
-
-if [ -z "$JAVA_HOME" ]; then
- JAVA="java"
-else
- JAVA="$JAVA_HOME/bin/java"
+if [ "x$KAFKA_HEAP_OPTS" = "x" ]; then
+ export KAFKA_HEAP_OPTS="-Xmx512M"
fi
-
-$JAVA $KAFKA_OPTS -cp $CLASSPATH kafka.examples.SimpleConsumerDemo $@
-
+exec $base_dir/bin/kafka-run-class.sh kafka.examples.SimpleConsumerDemo $@
|