本文共 1871 字，大约阅读时间需要 6 分钟。
-- Start
首先我们从一个最简单的例子开始，那就是kafka 集群只有一个broker。
Kafka 使用了 ZooKeeper，所以我们需要先启动 ZooKeeper。假设你的 Kafka 解压缩到目录 D:\0_Shangbo\App\kafka\kafka_2.12-1.1.0。首先，我们需要修改一下 config 目录下 zookeeper.properties 属性文件，将下面这行
dataDir=/tmp/zookeeper
替换成自己的目录（确保你的目录存在），如：
dataDir=D:/0_Shangbo/App/kafka/data/zookeeper然后，在 Windows 的命令提示符中执行如下的命令来启动 ZooKeeper。
set KAFKA_HOME=D:/0_Shangbo/App/kafka/kafka_2.12-1.1.0cd %KAFKA_HOME%/bin/windowszookeeper-server-start.bat %KAFKA_HOME%/config/zookeeper.properties
如果启动 ZooKeeper 时出现下面的错误，安装一个 jdk1.8 64位 试一试吧。
Unrecognized VM option 'UseCompressedOops'Error: Could not create the Java Virtual Machine.Error: A fatal exception has occurred. Program will exit.
在Windows 下启动 Kafka border 之前，我们需要修改一下 config 目录下的 server.properties 属性文件，将如下行
log.dirs=/tmp/kafka-logs
替换成自己的目录（确保你的目录存在），如：
log.dirs=D:/0_Shangbo/App/kafka/data/kafka/broker0
修改完之后，新打开一个命令提示符，执行如下的命令来启动 Kafka broker
set KAFKA_HOME=D:/0_Shangbo/App/kafka/kafka_2.12-1.1.0cd %KAFKA_HOME%/bin/windowskafka-server-start.bat %KAFKA_HOME%/config/server.properties
新打开一个命令提示符，下面的命令创建了一个名为topic0 的topic。
set KAFKA_HOME=D:/0_Shangbo/App/kafka/kafka_2.12-1.1.0cd %KAFKA_HOME%/bin/windowskafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic topic0你也可以运行下面的命令显示已经创建的 topic
kafka-topics.bat --list --zookeeper localhost:2181
下面的命令发送一条消息到topic0。
set KAFKA_HOME=D:/0_Shangbo/App/kafka/kafka_2.12-1.1.0cd %KAFKA_HOME%/bin/windowskafka-console-producer.bat --broker-list localhost:9092 --topic topic0This is a message
下面的命令从topic0 中接收消息。
set KAFKA_HOME=D:/0_Shangbo/App/kafka/kafka_2.12-1.1.0cd %KAFKA_HOME%/bin/windowskafka-console-consumer.bat --bootstrap-server localhost:9092 --topic topic0 --from-beginning
-- -- 声 明：转载请注明出处-- Last Edited on 2018-06-09-- Written by ShangBo on 2014-09-03-- End