Apache Kafka 安装升级指南

共计 1118 个字符，预计需要花费 3 分钟才能阅读完成。

在 Ubuntu12.04 server 上安装单结点 kafka，我的机器上之前已经安装过 zookeeper-3.4.5

根据官网的说明：http://kafka.apache.org/07/quickstart.html

下载一个 kafka-0.7.2.tar.gz，解压安装

> tar xzf kafka-<VERSION>.tgz
> cd kafka-<VERSION>
> ./sbt update
> ./sbt package 这个过程中会自动安装 Scala，需要花费点时间。

修改 /config/server.properties 文件，将里面的 hostname 修改为你主机的 IP，还需要修改 zk.connect 为 ZooKeeper 的 IP:2181。

然后重启 kafka-server-start.sh

bin/kafka-server-start.sh config/server.propertiesproducer 发送消息 bin/kafka-console-producer.sh –zookeeper localhost:2181 –topic test This is a test.consumer 获得消息 bin/kafka-console-consumer.sh –zookeeper localhost:2181 –topic test –from-beginningThis is a test. 升级到 0.8.0-beta1 升级之前要先将 ZooKeeper 中原版本的 kafka 生成的 znode 删除，包括：consumers, controller, brokers, controller_epoch 等。否则启动 kafka 会报错。另外，新版本的一些命令与原版本的有些相同，列举如下：bin/kafka-create-topic.sh –zookeeper 192.168.20.99:2181 –replica 1 –partition 1 –topic test
bin/kafka-list-topic.sh –zookeeper 192.168.20.99:2181
bin/kafka-console-producer.sh –broker-list 192.168.20.99:9092 –topic test
bin/kafka-console-consumer.sh –zookeeper 192.168.20.99:2181 –topic test –from-beginning

Kafka 的详细介绍 ：请点这里
Kafka 的下载地址 ：请点这里

相关阅读：

分布式发布订阅消息系统 Kafka 架构设计 http://www.linuxidc.com/Linux/2013-11/92751.htm