kafka搭建、学习(二)

window下Kafka安装

1.下载最新版本 

http://kafka.apache.org/downloads

解压后目录结构以下(注意:解压后的路径中不能有空格和(x86),否则没法启动apache

windows文件夹中为windows系统操纵的命令。bootstrap

2.启动服务器

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

3.建立主题(topic)

新建窗口建立一个名称为“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

4.建立消息提供者(producer)

建立producer:bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic testit

9092为刚才启动kafka服务器端口号io

发送一条消息hello

该消息目前没有消费者,会被暂存,有消费者后会被消息。

5.建立消息消费者(consumer)

新建窗口建立消费者:bin\windows\kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test --from-beginning

能够看见,hello已被消费。能够继续在producer发送消息,观察consumer接收状况。能够启多个consumer窗口观察接收状况。

以上为止,单节点kafka服务已完成。

相关文章
相关标签/搜索