这是我的数仓项目，大家记得用时改改

kafka-manager-2.0.0.2 原本下载个老版的，有bug无法创建topic； 无奈耗时2天，自己动手编译kafka-manager-2.0.0.2，编译成功，实测可用，大家放心使用！！

官方下载太慢了，这里提交一个下载包版本是2.11-1.0.0，因为受不来那个时间所以就上传了一个提供自己以后方便使用

什么是喷气机 是一个开源的，内存中的，分布式批处理和流处理引擎。 您可以使用它来处理大量的实时事件或大量的静态数据集。 为了提供一种规模感，Jet的单个节点已被证明可而延迟小于10毫秒。 它提供了Java API，可通过使用来构建流和批处理应用。 将应用程序部署到Jet群集后，Jet将自动使用群集上的所有计算资源来运行您的应用程序。 如果在应用程序运行时将更多节点添加到群集，Jet会自动扩展应用程序以在新节点上运行。 如果您从群集中删除节点，它将无缝地对其进行缩减，而不会丢失当前的计算状态，从而提供保证。 例如，您可以表示经典的单词计数问题，该问题使用以下API读取一些本地文件并将每个单

摘要:原创出处「朱小厮」欢迎转载，保留摘要，谢

摘要:原创出处「朱小厮」欢迎转载，保留摘要，谢

3台虚拟hadoop的安装配置，以前给朋友写的，现在免费分享出来，希望对大家有帮助，也可以来我的博客查找更多的相关内容https://tianlingqun.blog.csdn.net/

1、flink监听localhost的kafka，作为source，接收数据。 2、数据流转到elasticsearch 3、flink web ui提交jar文件，创建任务流程。 4、流程测试。

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 文件中，您需要添加一些必

kafka-schema-registrt-client