包含标签：kafka 的文章
-
Kafka消息队列的搭建与基础使用
一、Kafka消息队列 1、为什么需要消息队列？ 解耦 冗余 扩展性 灵活性 & 峰值处理能力 可恢复性 顺序保证 缓冲 异步通信 2、消息队列……admin 2021-12-18
-
Flink基于Java的WordCount，根据滑动窗口动态排序实现
背景 刚学习Flink没多久，之前用Spark做WordCount实现排序很简单，因为Spark做的WC是简单的批处理，直接排序就完事了，但是Flink的流处理需要考虑到状态（Sta…… -
大数据之Kafka看这一篇就够了
Kafka 异步通信原理 观察者模式 观察者模式（Observer），又叫发布-订阅模式（Publish/Subscribe） 定义对象间一种一对多的依赖关系，使得每当一个对象改…… -
sparkstreaming+flume+kafka实时流式处理完整流程
目录 sparkstreaming+flume+kafka实时流式处理完整流程 一、前期准备 二、实现步骤 1.引入依赖 2.日志收集服务器 3.日志接收服务器 4、spark集群处理…… -
structured streaming 入门级初使用（一）
1、准备 导入依赖 <dependency> <groupId>org.scala-lang</groupId> <artifactId>scala-library</ar…… -
sparkstreaming+flume+kafka实现实时日志处理
本实验自己做的亲测可以完整执行没如果你需要使用的话需要修改几个地方： flume配置文件中source和sinks的目标主机名 在idea中配置的log4j.properties文件…… -
-
文件传输利器之netty splice和fileRegion
因为项目需要需要做一个文件快速传输的工具。参考kafka和rocketmq的经验，文件传输有几个好用的方法，nio，零拷贝、顺序写入，内存映射（使用pagecache）。 …… -
单节点部署Gpmall
目录 一 、实验目标 二 、实验分析 2.1 规划节点 2.2 基础准备 三 、应用系统基础服务安装 3.1 修改主机名 3.2 配置本地YUM源 3.3 安装基础服务 3.3.1 安…… -
13张图让你百分百掌握kafka副本同步限流机制 |文末任性送35本技术书
🔥《Kafka运维管控平台》🔥 ✏️更强大的管控能力✏️ 🎾更高效的问题定位能力🎾 🌅更便捷的集群运维能力🌅 🎼更专业的资源治理🎼 🌞更友好的运维生……