java8stream源码-flink-kafka-java:好的kafka-java
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
文件中，您需要添加一些必
文件下载
资源详情
[{"title":"（ 54 个子文件 8.96MB ） java8stream源码-flink-kafka-java:好的kafka-java","children":[{"title":"flink-kafka-java-main","children":[{"title":"README.md <span style='color:#111;'> 11.92KB </span>","children":null,"spread":false},{"title":"kafka-producer <span style='color:#111;'> 1.43KB </span>","children":null,"spread":false},{"title":"int3.png <span style='color:#111;'> 157.02KB </span>","children":null,"spread":false},{"title":"word-count.zip <span style='color:#111;'> 9.15KB </span>","children":null,"spread":false},{"title":"HelloProducer.java <span style='color:#111;'> 1.50KB </span>","children":null,"spread":false},{"title":"vidgrid.PNG <span style='color:#111;'> 141.01KB </span>","children":null,"spread":false},{"title":"images","children":[{"title":"4test.png <span style='color:#111;'> 160.73KB </span>","children":null,"spread":false},{"title":"5run.png <span style='color:#111;'> 199.51KB </span>","children":null,"spread":false},{"title":"1Create.png <span style='color:#111;'> 131.03KB </span>","children":null,"spread":false},{"title":"3build.png <span style='color:#111;'> 169.73KB </span>","children":null,"spread":false},{"title":"2Jar.png <span style='color:#111;'> 147.88KB </span>","children":null,"spread":false},{"title":"Screenshot (360).png <span style='color:#111;'> 174.95KB </span>","children":null,"spread":false}],"spread":true},{"title":"kafka-streams <span style='color:#111;'> 1.63KB </span>","children":null,"spread":false},{"title":"Flink-Kafka-Interaction_Images","children":[{"title":"Screenshot (278).png <span style='color:#111;'> 336.17KB </span>","children":null,"spread":false},{"title":"Screenshot 2021-02-15 180812.png <span style='color:#111;'> 38.04KB </span>","children":null,"spread":false},{"title":"Screenshot 2021-02-15 180834.png <span style='color:#111;'> 20.87KB </span>","children":null,"spread":false},{"title":"kafka streams application.PNG <span style='color:#111;'> 133.08KB </span>","children":null,"spread":false},{"title":"1-kafka-flink-pipeline-1.png <span style='color:#111;'> 22.46KB </span>","children":null,"spread":false},{"title":"Screenshot 2021-02-15 180901.png <span style='color:#111;'> 124.09KB </span>","children":null,"spread":false}],"spread":true},{"title":"Vineetha_Application","children":[{"title":".project <span style='color:#111;'> 544B </span>","children":null,"spread":false},{"title":"pom.xml <span style='color:#111;'> 12.22KB </span>","children":null,"spread":false},{"title":"bin","children":[{"title":".gitignore <span style='color:#111;'> 184B </span>","children":null,"spread":false},{"title":".project <span style='color:#111;'> 544B </span>","children":null,"spread":false},{"title":"README.md <span style='color:#111;'> 1.25KB </span>","children":null,"spread":false},{"title":"pom.xml <span style='color:#111;'> 12.22KB </span>","children":null,"spread":false},{"title":".settings","children":[{"title":"org.eclipse.core.resources.prefs <span style='color:#111;'> 120B </span>","children":null,"spread":false},{"title":"org.eclipse.jdt.core.prefs <span style='color:#111;'> 421B </span>","children":null,"spread":false}],"spread":false},{"title":"LICENSE <span style='color:#111;'> 11.08KB </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"resources","children":[{"title":"log4j.properties <span style='color:#111;'> 1.17KB </span>","children":null,"spread":false}],"spread":false},{"title":"java","children":[{"title":"com","children":[{"title":"grallandco","children":[{"title":"demos","children":[{"title":"ReadFromKafka.class <span style='color:#111;'> 2.63KB </span>","children":null,"spread":false},{"title":"WriteToKafka.class <span style='color:#111;'> 2.45KB </span>","children":null,"spread":false},{"title":"WriteToKafka$SimpleStringGenerator.class <span style='color:#111;'> 2.74KB </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":true},{"title":"target","children":[{"title":"kafka-flink-101-1.0-SNAPSHOT.jar <span style='color:#111;'> 7.60MB </span>","children":null,"spread":false},{"title":"maven-archiver","children":[{"title":"pom.properties <span style='color:#111;'> 127B </span>","children":null,"spread":false}],"spread":false},{"title":"maven-status","children":[{"title":"maven-compiler-plugin","children":[{"title":"compile","children":[{"title":"default-compile","children":[{"title":"createdFiles.lst <span style='color:#111;'> 186B </span>","children":null,"spread":false},{"title":"inputFiles.lst <span style='color:#111;'> 189B </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false},{"title":"original-kafka-flink-101-1.0-SNAPSHOT.jar <span style='color:#111;'> 9.36KB </span>","children":null,"spread":false},{"title":"classes","children":[{"title":"log4j.properties <span style='color:#111;'> 1.17KB </span>","children":null,"spread":false},{"title":"META-INF","children":[{"title":"maven","children":[{"title":"com.grallandco.demos","children":[{"title":"kafka-flink-101","children":[{"title":"pom.xml <span style='color:#111;'> 12.22KB </span>","children":null,"spread":false},{"title":"pom.properties <span style='color:#111;'> 249B </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":false},{"title":"MANIFEST.MF <span style='color:#111;'> 101B </span>","children":null,"spread":false}],"spread":false},{"title":"com","children":[{"title":"grallandco","children":[{"title":"demos","children":[{"title":"ReadFromKafka$1.class <span style='color:#111;'> 1.21KB </span>","children":null,"spread":false},{"title":"ReadFromKafka.class <span style='color:#111;'> 2.19KB </span>","children":null,"spread":false},{"title":"WriteToKafka.class <span style='color:#111;'> 2.01KB </span>","children":null,"spread":false},{"title":"WriteToKafka$SimpleStringGenerator.class <span style='color:#111;'> 1.82KB </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false},{"title":".settings","children":[{"title":"org.eclipse.core.resources.prefs <span style='color:#111;'> 120B </span>","children":null,"spread":false},{"title":"org.eclipse.jdt.core.prefs <span style='color:#111;'> 421B </span>","children":null,"spread":false}],"spread":false},{"title":"LICENSE <span style='color:#111;'> 11.08KB </span>","children":null,"spread":false},{"title":"src","children":[{"title":"main","children":[{"title":"resources","children":[{"title":"log4j.properties <span style='color:#111;'> 1.17KB </span>","children":null,"spread":false}],"spread":false},{"title":"java","children":[{"title":"com","children":[{"title":"grallandco","children":[{"title":"demos","children":[{"title":"WriteToKafka.java <span style='color:#111;'> 2.17KB </span>","children":null,"spread":false},{"title":"ReadFromKafka.java <span style='color:#111;'> 1.99KB </span>","children":null,"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false}],"spread":false},{"title":".classpath <span style='color:#111;'> 1.21KB </span>","children":null,"spread":false}],"spread":true},{"title":"int1.png <span style='color:#111;'> 183.22KB </span>","children":null,"spread":false},{"title":"int2.png <span style='color:#111;'> 134.18KB </span>","children":null,"spread":false}],"spread":false}],"spread":true}]
评论信息
其他资源
- Objective-C程序设计 第6版 完整版 0分奉上
- 《北大版高等代数习题答案(PDF) 》1-9章
- MFC+OpenGL 读取并显示STL三维模型
- 省市区街道四级级联数据
- 基于SQL Server的HIS研究与实现
- 学校教材订购系统（超级完整版）
- 基于GTK的Linux环境下的简易任务管理器（附带源码）
- EPLAN项目模板
- 基于STM32F103单片机智能手表GSM短信GPS定位设计
- 找出所有最长公共子序列算法代码
- ICEM-CFD基础教程与实例
- stm32tcp程序
- COLLADAMax插件和DaeToGltf工具-2014.rar
- 在线考试系统 附源码和文档
- Hisilicon NVR td3531
- 细微的-源码
- docker-rpm-builder：利用docker功能，从任何Linux发行版甚至OSX为CentosRHELFedora构建本机RPM软件包。-源码
- HAAS机床操作面板培训.pdf
- YDT3747-2020区块链技术架构安全要求.pdf
- 深入嵌入式Java虚拟机
- scikit-learn 0.19 中文文档pdf完整文字版
- 《编译原理》全套的课程资源
- javaweb 项目集合
- 电子政务信息标准化指南第4部份2017版
免责申明
【只为小站】的资源来自网友分享，仅供学习研究，请务必在下载后24小时内给予删除，不得用于其他任何用途，否则后果自负。基于互联网的特殊性，【只为小站】 无法对用户传输的作品、信息、内容的权属或合法性、合规性、真实性、科学性、完整权、有效性等进行实质审查；无论 【只为小站】 经营者是否已进行审查，用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。
本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二条之规定，若资源存在侵权或相关问题请联系本站客服人员，zhiweidada#qq.com，请把#换成@，本站将给予最大的支持与配合，做到及时反馈和处理。关于更多版权及免责申明参见 版权及免责申明
本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二条之规定，若资源存在侵权或相关问题请联系本站客服人员，zhiweidada#qq.com，请把#换成@，本站将给予最大的支持与配合，做到及时反馈和处理。关于更多版权及免责申明参见 版权及免责申明