/ java8stream源码-flink-kafka-java:好的kafka-java

java8stream源码-flink-kafka-java:好的kafka-java

系统开源

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

文件下载

资源详情

[{"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":"Screenshot2021-02-15180812.png <span style='color:#111;'>38.04KB</span>","children":null,"spread":false},{"title":"Screenshot2021-02-15180834.png <span style='color:#111;'>20.87KB</span>","children":null,"spread":false},{"title":"kafkastreamsapplication.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":"Screenshot2021-02-15180901.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}]

评论信息

免责申明

【好快吧下载】的资源来自网友分享，仅供学习研究，请务必在下载后24小时内给予删除，不得用于其他任何用途，否则后果自负。基于互联网的特殊性，【好快吧下载】无法对用户传输的作品、信息、内容的权属或合法性、合规性、真实性、科学性、完整权、有效性等进行实质审查；无论【好快吧下载】经营者是否已进行审查，用户均应自行承担因其传输的作品、信息、内容而可能或已经产生的侵权或权属纠纷等法律责任。
本站所有资源不代表本站的观点或立场，基于网友分享，根据中国法律《信息网络传播权保护条例》第二十二条之规定，若资源存在侵权或相关问题请联系本站客服人员，8686821#qq.com，请把#换成@，本站将给予最大的支持与配合，做到及时反馈和处理。关于更多版权及免责申明参见版权及免责申明