用的kafka版本是0.8.0的，里面没有集群启动的脚本，所以写了一个集群启动的脚本如下：

#!/bin/bash
BROKERS="test6 test5 test10"
KAFKA_HOME="/usr/lib/kafka"
for broker in $BROKERS
do  
	echo "INFO:starting kafka server on ${broker}"
	ssh $broker -C "${KAFKA_HOME}/bin/kafka-server-start.sh ${KAFKA_HOME}/config/server.properties &" &
	if [ $ != 0 ];
	then 
		echo "Can not starting kafka server on host ${broker}";
		exit 1;
	fi
done