Kappa架构中使用数据户的存储方案替代kafka的存储方案有什么好处? Kappa架构中使用数据户的存储方案替代kafka的存储方案有什么好处?... 帅平 /大数据 /2024-02-27 /1 评论 /50 阅读
Apache Druid系列(七)Druid导入kafka的数据 上文《Apache Druid系列(六)Druid导入本地数据》我们演示了导入本地文件这种有界流的数据,本文的话我们介绍下导入无界流的数据,主要的演示对象是直接导入kafka的数据。下面直接开始1)编写一个kafka... Rae /大数据 /2024-02-02 /0 评论 /175 阅读
数据湖系列(二十六)Flink sql近实时写入iceberg 前面我们介绍了使用spark近实时写把kafka的数据写入iceberg,本文的话,我们使用flink sql的形式来把kafka的数据近实时写入到iceberg里面去。在flink中,这种写入其实主要是依赖于kaf... Rae /数据仓库 /2024-01-31 /0 评论 /308 阅读
使用scala编写kafka的生产者和消费者案例 最近在演示spark相关的内容,所以这里单独出一个案例,使用scala编写一个kafka的生产者和消费者的代码案例,直接上代码:生产者代码示例:package com.kafka.produceri... Rae /消息中间件 /2024-01-29 /0 评论 /213 阅读