the 0.9.0.0 release and un-tar it.

> tar -xzf kafka_2.11-0.9.0.0.tgz > cd kafka_2.11-0.9.0.0

Kafka uses ZooKeeper so you need to first start a ZooKeeper server if you don't already have one. You can use the convenience script packaged with kafka to get a quick-and-dirty single-node ZooKeeper instance.

> bin/zookeeper-server-start.sh config/zookeeper.properties [2013-04-22 15:01:37,495] INFO Reading configuration from:config/zookeeper.properties (org.apache.zookeeper.server.quorum.QuorumPeerConfig) ...

Now start the Kafka server:

> bin/kafka-server-start.sh config/server.properties [2013-04-22 15:01:47,028] INFO Verifying properties (kafka.utils.VerifiableProperties) [2013-04-22 15:01:47,051] INFO Property socket.send.buffer.bytes is overridden to 1048576 (kafka.utils.VerifiableProperties) ...

Let's create a topic named "test" with a single partition and only one replica:

> bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test

We can now see that topic if we run the list topic command:

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

Alternatively, instead of manually creating topics you can also configure your brokers to auto-create topics when a non-existent topic is published to.

Kafka comes with a command line client that will take input from a file or from standard input and send it out as messages to the Kafka cluster. By default each line will be sent as a separate message.

Run the producer and then type a few messages into the console to send to the server.

> bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test This is a message This is another message

Kafka also has a command line consumer that will dump out messages to standard output.

> bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning This is a message This is another message

If you have each of the above commands running in a different terminal then you should now be able to type messages into the producer terminal and see them appear in the consumer terminal.

All of the command line tools have additional options; running the command with no arguments will display usage information documenting them in more detail.

二、kafka环境配置(若省略此步，其他主机上的客户端访问时会报错)

port: broker节点使用端口号 默认 9092

log.dir: 消息目录位置

3，执行librdkafka的例程

修改kafka的配置文件后再重启kafka服务以及消费者程序

此时在客户端主机执行

examples/rdkafka_example -P -b 128.1.0.149:9092 -t test    （128.1.0.149换成你自己的IP）

后，会在服务端的消费者执行窗口看到客户端你输入的字符

对于初学者可能参数都不知道该怎么加，可以通过三个地方学习

a,第一步中的kafka生产者测试实例，

b，第三步中的librdkafka生产者实例，

c,执行rdkafka_example时不加参数会提示帮助。

最重要的一点还是要了解kafka的框架。