步骤1：下载程式码
下载 2.5.0发行版并将其解压缩。
> tar -xzf kafka_2.12-2.5.0.tgz
> cd kafka_2.12-2.5.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 --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
现在，如果我们运行list topic命令，便可以看到该主题：
> bin/kafka-topics.sh --list --bootstrap-server localhost:9092 test
第4步：发送一些消息
Kafka带有一个命令行客户端，它将从文件或标准输入中获取输入，并将其作为消息发送到Kafka集群。默认情况下，每行将作为单独的消息发送。
运行生产者，然后在控制台中键入一些消息以发送到服务器。
> bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic test
This is a message
This is another message
步骤5：启动消费者
Kafka还有一个命令行使用者，它将消息转储到标准输出
> bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
This is a message
This is another message