Kafka 0.7.2 单机环境搭建

当下载完Kafka后，进行解压，其目录结构如下：

• bin
• config
• contrib
• core
• DISCLAIMER
• examples
• lib
• lib_managed
• LICENSE
• NOTICE
• perf
• project
• README.md
• sbt
• system_test

Kafka是用scala编写的，可以运行在JVM上，因此不需要单独搭建scala环境，在后面需要编程的时候我们再进行scala的配置。

1.安装Java环境，本机是1.7.0_09

2.解压Kafka，tar -xzvf kafka-0.7.2-incubating-src.tgz

3.下载Kafka的依赖包和构建环境，进入解压后的目录执行如下命令：

./sbt update

./sbt package

4.上述步骤执行完后，kafka的工作环境就配置好了，下面启动服务进行测试。

（1）启动zookeeper server

bin/zookeeper-server-start.sh config/zookeeper.properties &

（2）启动Kafka

bin/kafka-server-start.sh config/server.properties &

接下来测试连接，

（3）运行producer

bin/kafka-console-producer.sh --zookeeper localhost:2181 --topic test

（4）运行consumer

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

在producer终端输入如下信息

    Kafka message test

在consumer终端就会收到在producer终端中输入的信息

    Kafka message test

到这一步，就说明单机版部署成功了。

后面可以进一步的研究下分布式部署。