文章 2025-01-08 来自:开发者社区

云消息队列 Kafka 版 V3 系列荣获信通院“云原生技术创新标杆案例”

2024 年 12 月 24 日,由中国信息通信研究院(以下简称“中国信通院”)主办的“2025 中国信通院深度观察报告会:算力互联网分论坛”,在北京隆重召开。本次论坛以“算力互联网 新质生产力”为主题,全面展示中国信通院在算力互联网产业领域的研究、实践与业界共识,与产业先行者共同探索算力互联网产业未来发展的方向。 会议公布了“2024 年度云原生与应用现代化标杆案例”评选结果...

云消息队列 Kafka 版 V3 系列荣获信通院“云原生技术创新标杆案例”
文章 2024-10-14 来自:开发者社区

大数据-102 Spark Streaming Kafka ReceiveApproach DirectApproach 附带Producer、DStream代码案例

点一下关注吧!!!非常感谢!!持续更新!!! 目前已经更新到了: Hadoop(已更完) HDFS(已更完) MapReduce(已更完) Hive(已更完) Flume(已更完) Sqoop(已更完) Zookeeper(已更完) HBase(已更完) Redis (已更完) Kafka(已更完) ...

大数据-102 Spark Streaming Kafka ReceiveApproach DirectApproach 附带Producer、DStream代码案例
文章 2024-08-10 来自:开发者社区

"深入实践Kafka多线程Consumer:案例分析、实现方式、优缺点及高效数据处理策略"

Apache Kafka作为一款分布式流处理平台,以其高吞吐量和可扩展性在大数据处理领域占据了重要地位。在实际应用中,为了提升数据处理的效率和灵活性,我们常常需要采用多线程的方式来消费Kafka中的数据。本文将通过一个案例分析,详细探讨Kafka多线程Consumer的实现方式、优缺点以及具体示例代码。 案例分析:高并发数据消...

问答 2024-07-10 来自:开发者社区

有没有flink1.17版本,从kafka把数据写入到hbase的demo案例呢?

有没有flink1.17版本,从kafka把数据写入到hbase的demo案例呢kafka版本:3.6.1hbase2.4.x?

问答 2024-06-05 来自:开发者社区

在Flink CDC中采集MYSql数据写入到Kafka,有没有案例参考一下?

在Flink CDC中采集MYSql数据写入到Kafka,有没有案例参考一下?

文章 2024-03-29 来自:开发者社区

Flume+Kafka整合案例实现

一、为什么要集成Flume和Kafka 我们很多人在在使用Flume和kafka时,都会问一句为什么要将Flume和Kafka集成?那首先就应该明白业务需求,一般使用Flume+Kafka架构都是希望完成实时流式的日志处理,后面再连接上Flink/Storm/Spark Streaming等流式实时处理技术,从而完成日志实时解析的目标。第一、如果Flume直接对接实时计算框架,当数据采集...

Flume+Kafka整合案例实现
文章 2023-12-26 来自:开发者社区

基于Flume+Kafka+Hbase+Flink+FineBI的实时综合案例(五)FineBI可视化

22:FineBI配置数据集目标:实现FineBI访问MySQL结果数据集的配置实施安装FineBI参考《FineBI Windows版本安装手册.docx》安装FineBI配置连接数据连接名称:Momo 用户名:root 密码:自己MySQL的密码 数据连接URL:jdbc:mysql://node1:3306/momo?useUnicode=true&characterEncodin....

基于Flume+Kafka+Hbase+Flink+FineBI的实时综合案例(五)FineBI可视化
文章 2023-12-26 来自:开发者社区

基于Flume+Kafka+Hbase+Flink+FineBI的实时综合案例(四)实时计算需求及技术方案

16:实时计算需求及技术方案目标:了解实时计算需求及技术方案路径step1:实时计算需求step2:技术方案实施实时计算需求实时统计消息总量select count(*) from tbname;实时统计各个地区发送消息的总量select sender_area,count(*) from tbname group by sender_area;实时统计各个地区接收消息的总量select rec....

基于Flume+Kafka+Hbase+Flink+FineBI的实时综合案例(四)实时计算需求及技术方案
文章 2023-12-26 来自:开发者社区

基于Flume+Kafka+Hbase+Flink+FineBI的实时综合案例(三)离线分析

08:离线分析:Hbase表设计及构建目标:掌握Hbase表的设计及创建表的实现路径step1:基础设计step2:Rowkey设计step3:分区设计step4:建表实施基础设计Namespace:MOMO_CHATTable:MOMO_MSGFamily:C1Qualifier:与数据中字段名保持一致Rowkey设计查询需求:根据发件人id + 收件人id + 消息日期 查询聊天记录发件人账....

基于Flume+Kafka+Hbase+Flink+FineBI的实时综合案例(三)离线分析
文章 2023-12-26 来自:开发者社区

基于Flume+Kafka+Hbase+Flink+FineBI的实时综合案例(二)数据源

04:数据源目标:了解数据源的格式及实现模拟数据的生成路径step1:数据格式step2:数据生成实施数据格式消息时间发件人昵称发件人账号发件人性别发件人IP发件人系统发件人手机型号发件人网络制式发件人GPS收件人昵称收件人IP收件人账号收件人系统收件人手机型号收件人网络制式收件人GPS收件人性别消息类型双方距离消息msg_timesender_nickynamesender_accountse....

基于Flume+Kafka+Hbase+Flink+FineBI的实时综合案例(二)数据源

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

云消息队列

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

+关注