Kafka 文档（快速开始）

快速开始

本教程假设你正在从头开始，而且没有任何Kafka或ZooKeeper数据，因为基于unix和Windows平台的Kafka控制台脚本不一样，在Windows平台上使用bin\windows\而不是bin/，并将脚本扩展名更改成.bat。

步骤1：下载代码

下载2.0.0版本并解压tar文件。

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

步骤2：启动服务

Kafka使用ZooKeeper，因此若是没有的话，你须要先启动一个ZooKeeper服务，你能够使用与kafka打包的便利脚原本得到一个快速而不纯净的单节点ZooKeeper实例。

> 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)
...

如今启动Kafka服务：

> 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)
...

步骤3：建立主题

让咱们建立一个分区和一个副本的名为“test”的主题：

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

若是运行list topic命令，就能够看到这个主题：

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

另外，你也能够将代理配置为在发布不存在的主题时自动建立主题，而不是手工建立主题。

步骤4：发送消息

Kafka附带一个命令行客户端，该客户端将从文件或标准输入接收输入，并将其做为消息发送到Kafka集群，默认状况下，每一行将做为单独的消息发送。

运行该生产者，而后将一些消息输入到控制台，以发送到服务器。

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