日期:2014-05-16 浏览次数:20937 次
在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 testThis is a test.consumer获得消息bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginningThis is a test.
参考:http://my.oschina.net/ielts0909/blog/93190
http://kafka.apache.org/07/quickstart.html