admin 管理员组

文章数量: 1184232

一、下载kafka

http://kafka.apache/downloads

选择二进制版本。

二、安装kafka

下载到本地后，将文件解压到本地磁盘下，该文件夹包括了所有相关的运行文件及配置文件，其子文件夹bin\windows 下放的是在Windows系统启动zookeeper和kafka的可执行文件，子文件夹config下放的是zookeeper和kafka的配置文件。

  1. 将安装包在本地解压。
$ tar -xzf kafka_2.13-2.8.0.tgz
$ cd kafka_2.13-2.8.0

注意：您的本地环境必须安装 Java 8+。

  1. 启动zookeeper（不要关闭窗口）
$ bin\windows\zookeeper-server-start.bat config\zookeeper.properties
  1. 启动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

本文标签： Windows Kafka

版权声明：本文标题：windows安装kafka 内容由网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：http://roclinux.cn/b/1760050840a3149316.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。