【文件属性】：
文件名称：java8stream源码-flink-kafka-java:好的kafka-java
文件大小：8.96MB
文件格式：ZIP
更新时间：2021-06-04 17:25:17
系统开源
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
文件中，您需要添加一些必
【文件预览】：
flink-kafka-java-main
----README.md(12KB)
----kafka-producer(1KB)
----int3.png(157KB)
----word-count.zip(9KB)
----HelloProducer.java(1KB)
----vidgrid.PNG(141KB)
----images()
--------4test.png(161KB)
--------5run.png(200KB)
--------1Create.png(131KB)
--------3build.png(170KB)
--------2Jar.png(148KB)
--------Screenshot (360).png(175KB)
----kafka-streams(2KB)
----Flink-Kafka-Interaction_Images()
--------Screenshot (278).png(336KB)
--------Screenshot 2021-02-15 180812.png(38KB)
--------Screenshot 2021-02-15 180834.png(21KB)
--------kafka streams application.PNG(133KB)
--------1-kafka-flink-pipeline-1.png(22KB)
--------Screenshot 2021-02-15 180901.png(124KB)
----Vineetha_Application()
--------.project(544B)
--------pom.xml(12KB)
--------bin()
--------target()
--------.settings()
--------LICENSE(11KB)
--------src()
--------.classpath(1KB)
----int1.png(183KB)
----int2.png(134KB)