共计 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