KafKa的介绍我这就不赘叙了,有心想了解的小伙伴可以去官网查看。 kafka中文文档:https://kafka.apachecn.org/
开始正题: 一、下载最新版本,我用的是2.12-2.6.0 http://kafka.apache.org/downloads ps:安装前提:JDK1.8,没有的同学自行安装 二、开始安装 1.解压压缩包 2.在解压文件下新建一个存放日志的logs
3.修改配置文件:config\server.properties 找到log.dirs 然后修改日志存放位置,我是放在e盘 log.dirs=E:\kafka\kafka_2.12-2.6.0/logs
4、启动 注意:首先要启动zookeeper,由于我们下载的安装包自带了zookeeper,就不用对zookeeper进行配置。 打开五个cmd,路径转到E:\kafka\kafka_2.12-2.6.0\bin\windows 第一步: 启动自带的zookeeper 执行: zookeeper-server-start.bat …\config\zookeeper.properties 第二步:启动kafka 执行: kafka-server-start.bat …\config\server.properties 参考上图
第三步:创建topic 执行:kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test1 会有创建成功的提示,test1就是主题名,可自行修改
第四步:创建消费者 执行:kafka-console-consumer.bat --bootstrap-server localhost:9092 --topic test1 --from-beginning 主题名要对应得上
第五步:创建生产者 执行:kafka-console-producer.bat --broker-list localhost:9092 --topic test1
看看效果 自此,就安装完成了