Kafka的安装测试

在安装kafka之前，确保你的服务器上面JDK配置正确，最好用1.7的。

下载地址：

       http://kafka.apache.org/downloads.html

下载完成之后执行解压命令：  tar -zxvf kafka_2.10-0.8.1.1.tgz

	启动服务
	      首先启动zookeeper服务
	      bin/zookeeper-server-start.sh config/zookeeper.properties
	      启动Kafka
      bin/kafka-server-start.sh config/server.properties >/dev/null 2>&1 &

查看服务是否启动：

创建topic:

	创建topic
	        创建一个"test"的topic，一个分区一个副本
          bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

查看主题

	查看主题
	       bin/kafka-topics.sh --list --zookeeper localhost:2181

查看主题详情

	查看主题详情
	        bin/kafka-topics.sh --describe --zookeeper localhost:2181 --topic test

创建生产者：

	bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test 

创建消费者：

	bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning