解压后目录结构以下(注意:解压后的路径中不能有空格和(x86),否则没法启动)apache
windows文件夹中为windows系统操纵的命令。bootstrap
Kafka使用ZooKeeper,因此你须要先启动一个ZooKeeper服务器,若是你尚未。 您能够使用随kafka一块儿打包的便捷脚原本获取一个快速的单节点ZooKeeper实例。windows
执行zookeeper启动命令:bin\windows\zookeeper-server-start.bat config\zookeeper.properties服务器
新建窗口启动Kafka服务器:bin\windows\kafka-server-start.bat config\server.propertiesspa
新建窗口建立一个名称为“test”的主题:server
bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testget
查看建立的主题:bin\windows\kafka-topics.bat --list --zookeeper localhost:2181kafka
建立producer:bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic testit
9092为刚才启动kafka服务器端口号io
发送一条消息hello
该消息目前没有消费者,会被暂存,有消费者后会被消息。
新建窗口建立消费者:bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning
能够看见,hello已被消费。能够继续在producer发送消息,观察consumer接收状况。能够启多个consumer窗口观察接收状况。
以上为止,单节点kafka服务已完成。