java8流源码大数据项目-Flink-Kafka-Java
使用
flink
和
kafka
等大数据工具对数据集执行操作。
小组成员
莫汉·克里希纳·阿拉瓦拉
示范技巧:
我将在windows机器上演示kafka的安装和配置。
先决条件:
卡夫卡
2.13
动物园管理员
3.4
Maven
Java(Java
8
或
Java
11)
集成开发环境
电源外壳
卡夫卡简介
您可以通过单击以下内容来安装
kafka
下载完成后,就可以得到一个tar文件。
使用命令提取tar文件
焦油-xzf
kafka_2.13-2.7.0.tgz
cd
kafka_2.13-2.7.0
之后需要用C:\kafka_2.13-2.7.0设置KAFKA_HOME下的环境变量
使用
Maven
设置
Kafka
为了演示,我正在
IntelliJ
IDE
中使用
maven
创建一个项目。
您需要在左窗格中选择
Maven
并在开始屏幕上选择
Java
版本。
现在点击完成
接下来,您需要选择项目的名称,这将是工件
ID,然后单击完成。
现在,您需要将依赖项添加到
pom.xml
文件中,您需要添加一些必
2022-07-22 14:07:33
8.96MB
系统开源
1