Apache Kafka 安装升级指南

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

根据官网的说明:

下载一个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 的下载地址请点这里

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:http://www.heiqu.com/cfb1b53519c38e5f35e940bb641186d8.html