KAFKA-425 Wrong class name in scripts. Patch from Akira Kitada reviewed by Jay Kreps.

git-svn-id: https://svn.apache.org/repos/asf/incubator/kafka/branches/0.8@1373054 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Edward Jay Kreps 2012-08-14 19:56:36 +00:00
parent a8790784df
commit d482531810
3 changed files with 3 additions and 3 deletions

View File

@ -14,4 +14,4 @@
# 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.
$(dirname $0)/kafka-run-class.sh kafka.tools.SimpleConsumerPerformance $@ $(dirname $0)/kafka-run-class.sh kafka.perf.SimpleConsumerPerformance $@

View File

@ -28,7 +28,7 @@ $base_dir/../../bin/kafka-server-start.sh $base_dir/config/server.properties 2>&
sleep 4 sleep 4
echo "start producing $num_messages messages ..." echo "start producing $num_messages messages ..."
$base_dir/../../bin/kafka-run-class.sh kafka.tools.ProducerPerformance --brokerinfo broker.list=0:localhost:9092 --topic test01 --messages $num_messages --message-size $message_size --batch-size 200 --threads 1 --reporting-interval 100000 num_messages --async --compression-codec 1 $base_dir/../../bin/kafka-run-class.sh kafka.perf.ProducerPerformance --brokerinfo broker.list=0:localhost:9092 --topic test01 --messages $num_messages --message-size $message_size --batch-size 200 --threads 1 --reporting-interval 100000 num_messages --async --compression-codec 1
echo "wait for data to be persisted" echo "wait for data to be persisted"
cur_offset="-1" cur_offset="-1"

View File

@ -28,7 +28,7 @@ $base_dir/../../bin/kafka-server-start.sh $base_dir/config/server.properties 2>&
sleep 4 sleep 4
echo "start producing $num_messages messages ..." echo "start producing $num_messages messages ..."
$base_dir/../../bin/kafka-run-class.sh kafka.tools.ProducerPerformance --brokerinfo broker.list=0:localhost:9092 --topic test01 --messages $num_messages --message-size $message_size --batch-size 200 --threads 1 --reporting-interval 100000 num_messages --async $base_dir/../../bin/kafka-run-class.sh kafka.perf.ProducerPerformance --brokerinfo broker.list=0:localhost:9092 --topic test01 --messages $num_messages --message-size $message_size --batch-size 200 --threads 1 --reporting-interval 100000 num_messages --async
echo "wait for data to be persisted" echo "wait for data to be persisted"
cur_offset="-1" cur_offset="-1"