install kafka

载kafka官网编译好的二进制文件

wget http://apache.fayea.com/kafka/0.8.2.1/kafka_2.10-0.8.2.1.tgz
tar -xzvf kafka_2.10-0.8.2.1.tgz
cd kafka_2.10-0.8.2.1

启动zookeeper

bin/zookeeper-server-start.sh config/zookeeper.properties
启动kafka server

首先修改server.properties配置文件，将host.name 绑定到localhost，否则本地测试会报错。

host.name=localhost
启动server：

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

创建一个topic

名字叫”HelloWorld”, 只有一个分区和一个备份。

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic HelloWorld
输出:

Created topic "HelloWorld".
可以使用—-list选项来查看当前的所有的topic。

bin/kafka-topics.sh --list --zookeeper localhost:2181

输出:
HelloWorld

生产者Producer

Kafka提供了一个命令行的工具，可以从输入文件或者命令行中读取消息并发送给Kafka集群。每一行是一条消息。

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic HelloWorld
输入:

HelloWorld!       
HelloKafka!

消费者consumer

Kafka也提供了一个消费消息的命令行工具。

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

输出:

HelloWorld!
HelloKafka!
可以看到消费者成功的接收到了topic HelloWorld的消息。