栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

kafka的安装与使用(一)

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

kafka的安装与使用(一)

kafka的安装与使用(一)
	最近接触消息中间件,把使用过程中记录一下!
1. 下载与安装
	任何文档都要以官方文档为准,英文多看两眼你会发现比上次更加熟悉了。(* ̄︶ ̄)!
	首先附上官方文档:[kafka官网](https://kafka.apache.org/documentation/#quickstart)

注意:kafka需要JDK1.8以上的版本,并且环境要配置好,不懂得可以去百度一个。windows和linux的java环境配置教程;
下载kafka:本文是以【kafka_2.13-2.4.1】和windows环境演示为例,不同的版本后面的代码可能存在小问题,具体的问下度娘可以解决,下载下来后自己找个目录解压出来即可!我这解压后如下图:

新建一个data目录即可,然后进入config目录,打开:zookeeper.properties 文件找到dataDir=“配置的data目录”,我这是D:/lyxl/kafka_2.13-2.4.1/data,保存关闭。如下图:

接着打开server.properties配置下日志的路径:找到log.dirs=“日志存放的路径”;

到此安装配置基本完成!

2. 简单使用

使用命令框进入kafka目录:
注意:windows要进入bin下面的windows路径,运行对应的bat文件,linux则在bin下运行sh文件就行。
下面所有的命令都是在下面这个路径下运行。

cd D:lyxlkafka_2.13-2.4.1binwindows

启用zookeeper
开启第一个命令窗口

zookeeper-server-start.bat ../../config/zookeeper.properties

启用kafka
开启第二个命令窗口

kafka-server-start.bat ../../config/server.properties

创建一个主题来存储您的事件
开启第三个命令窗口

kafka-topics.bat --create --topic quickstart-events --bootstrap-server localhost:9092

开始消息发布窗口
继续在第三个命令窗口

kafka-console-producer.bat --broker-list hadoop132:9092,hadoop133:9092,hadoop134:9092 --topic first

开始消息消费窗口
开启第四个命令窗口

kafka-console-consumer.bat --bootstrap-server hadoop132:9092 --topic first

现在就可以在消息发布窗口发送消息,消费窗口接收消息了。如图:

3. 问题:

创建消费者报错:zookeeper is not a recognized option
原因是:版本不同的问题导致一些语法有变动,百度下就可以解决,小问题!

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/919275.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号