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-java-demo 基于java的kafka生产消费者示例。 mvn

用java实现向kafka写数据以及从kafka消费数据，kafka版本支持0.10以上