大家好，欢迎来到IT知识分享网。
一、下载kafka
http://kafka.apache.org/downloads
选择二进制版本。
二、安装kafka
下载到本地后，将文件解压到本地磁盘下，该文件夹包括了所有相关的运行文件及配置文件，其子文件夹bin\windows 下放的是在Windows系统启动zookeeper和kafka的可执行文件，子文件夹config下放的是zookeeper和kafka的配置文件。
- 将安装包在本地解压。
$ tar -xzf kafka_2.13-2.8.0.tgz
$ cd kafka_2.13-2.8.0
注意：您的本地环境必须安装 Java 8+。
- 启动zookeeper（不要关闭窗口）
$ bin\windows\zookeeper-server-start.bat config\zookeeper.properties
- 启动kafka（打开另一个终端会话并运行）
$ bin\windows\kafka-server-start.bat config\server.properties
三、创建Topic
Kafka中创建一个Topic，名称为test
$ bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
查看当前所有topic
$ bin\windows\kafka-topics.bat --list --zookeeper localhost:2181
四、测试生产者消费者
开启生产者
$ bin\windows\kafka-console-producer.bat --broker-list localhost:9092 --topic deviceTopic
开启消费者
$ bin\windows\kafka-console-consumer.bat --bootstrap-server 127.0.0.1:9092 --topic output --from-beginning
免责声明：本站所有文章内容,图片，视频等均是来源于用户投稿和互联网及文摘转载整编而成，不代表本站观点，不承担相关法律责任。其著作权各归其原作者或其出版社所有。如发现本站有涉嫌抄袭侵权/违法违规的内容,侵犯到您的权益，请在线联系站长,一经查实,本站将立刻删除。 本文来自网络,若有侵权，请联系删除，如若转载，请注明出处：https://yundeesoft.com/24649.html
