Kafka 文档（快速开始）

快来打我* 2021-09-18 14:20 319阅读 0赞

## 快速开始 ##

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

### 步骤1：下载代码 ###

[下载2.0.0版本][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

[2.0.0]: https://www.apache.org/dyn/closer.cgi?path=/kafka/2.0.0/kafka_2.11-2.0.0.tgz