ICode9

精准搜索请尝试: 精确搜索
首页 > 其他分享> 文章详细

Kafka的安装

2022-06-02 14:03:18  阅读:141  来源: 互联网

标签:KafkaWordCount sbt Kafka 新开 文件夹 终端 共享 安装


安装sbt

1.下载并解压至/usr/local

 

 赋予权限并将bin目录下的sbt-launch.jar复制到sbt

 

 

 

 安装目录下创建shell脚本文件,启动sbt

 

 

增加可执行权限,并查看sbt版本信息

 

 

 Kafka的安装

解压至/usr/local,改名为kafka并赋予权限

 

 

打开终端,启动Zookeeper服务,再开一个终端启动kafka

 

 新开终端,创建topic并查看

 

新开一个终端作监控输入终端

 

 

 

编辑打包程序simple.sbt

 

 

 

 

 

 启动Hadoop,新开终端,执行如下命令 运行程序

 

 

 

 “localhost:9092 wordsender 3 5”是提供给KafkaWordProducer程序 的4个输入参数,第1个参数“localhost:9092”是Kafka的Broker的地址,第2个参 数“wordsender”是Topic的名称,我们在KafkaWordCount.scala代码中已经把Topic名称 写死掉,所以,KafkaWordCount程序只能接收名称为“wordsender”的Topic。第3个参 数“3”表示每秒发送3条消息,第4个参数“5”表示每条消息包含5个单词(实际上就是5个整 数)

 

 

 新开终端,运行KafkaWordCount程序

 

 关闭终端的时候要先ctrl+c结束进程

 

 

设备——共享文件夹——共享文件夹

 

 

 

 

 固定分配——其它

 

 

 

 

 

创建共享文件夹

 

 

 

 

 

 设置好共享名后,进入Ubuntu系统,打开终端,先执行命令,在挂载点目录添加“bdshare”目录,接着执行"mount -t vboxsf sharefile  /mnt/bdshare/",就能完成共享文件夹的设置。

 

设置自动挂载,重启虚拟机系统共享仍在。

 

 

 

 

 

 

参考: https://www.cnblogs.com/dong-blog/p/7207831.html

 

 

 

 

标签:KafkaWordCount,sbt,Kafka,新开,文件夹,终端,共享,安装
来源: https://www.cnblogs.com/codecodee/p/16285475.html

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有