网站首页 scala2.12

• 

  大数据Hadoop之——Apache Hudi 数据湖实战操作

  一、概述...

  2025-03-30 baijin 博客文章 43 ℃ 0 评论
• 

  基于 Flink CDC YAML 的 MySQL 到 Kafka 流式数据集成

  准备阶段准备FlinkStandalone集群1.下载Flink1.19.2[1]压缩包，解压后并跳转至Flink目录下，设置FLINK_HOME为flink-1.19.2所在目录。...

  2025-03-30 baijin 博客文章 33 ℃ 0 评论
• 

  Flink SQL 命令行报错（flink sql window）

  flink-1.19.1-bin-scala_2.12.tgz在命令行执行如下命令FlinkSQL>SELECTname,COUNT(*)AScntFROM(VALUES('Bob'),('Alice'),('Gre...

  2025-03-30 baijin 博客文章 41 ℃ 0 评论
• 

  手把手带你部署ZooKeeper（zookeeper部署方式）

  Kafka服务依赖于ZooKeeper（暂不考虑KRaft模块），所以部署Kafka前需要先部署ZooKeeper服务。部署ZooKeeper服务有两种方式：...

  2025-03-30 baijin 博客文章 31 ℃ 0 评论
• 

  flink1.20集群环境搭建（flinkonyarn集群部署）

  前置准备hadoop集群环境用flink集群规划vm100:TaskManagervm101:TaskManager+historyservervm102:JobManager+TaskManager...

  2025-03-30 baijin 博客文章 32 ℃ 0 评论
• 

  群晖DS218+部署kafka（群晖ds218j）

  起因是懒我是个Java程序员，在家写代码时常用到redis、mysql、kafka这些基础服务，通常做法是打开电脑，启动redis、mysql、kafka，用完再关闭电脑，总觉得这些操作挺麻烦（您想骂我懒么？您骂得对.....）群晖解决烦恼...

  2025-03-30 baijin 博客文章 27 ℃ 0 评论
• 

  大数据Hadoop之——Kafka Streams原理介绍与简单应用示例

  一、KafkaStreams概述...

  2025-03-30 baijin 博客文章 25 ℃ 0 评论
• 

  二、Flink部署（flink运行流程）

  1.Flink集群角色Flink提交作业和执行任务时，需要几个关键组件客户端（Client）：代码由客户端获取并做转换，之后提交给JobManager...

  2025-03-30 baijin 博客文章 35 ℃ 0 评论
• 

  Scala安装及环境配置（scala安装及环境配置linux）

  概述scala程序运行需要依赖于Java类库，那么必须要有...

  2025-03-30 baijin 博客文章 27 ℃ 0 评论
• 

  Kafka 4.0.0 登场:移除 ZooKeeper、重塑实时数据流处理新格局

  ApacheKafka4.0.0发布！重大更新全解析...

  2025-03-30 baijin 博客文章 30 ℃ 0 评论