包含标签:kafka 的文章
-
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运维管控平台》? ✏️更强大的管控能力✏️ ?更高效的问题定位能力? ?更便捷的集群运维能力? ?更专业的资源治理? ?更友好的运维生…… -
七、浅析kafka状态机
此文章基于kafka2.5 kafka状态机有两种,一种是ReplicaStateMachine副本状态机,另一种是PartitionStateMachine分区状态机,下面我们就来分别介绍一下 状…… -
Flink 的侧输出 和一个流拆分成多个流
1. Flink 侧输出流 官网 :https://nightlies.apache.org/flink/flink-docs-release-1.14/docs/dev/datastream/side_output/ 1.1 理解 侧输出流就是将问题…… -
什么是Kafka
什么是Kafka 概念 网址: Kafka 官网 描述: Kafka是由Apache软件基金会开发的一个开源流处理平台,由Scala和Java编写。 Kafka是一种高吞吐量的分布…… -
【玩转Kafka】海量日志收集实战之架构介绍与日志输出
海量日志收集实战 话不多说,看架构图: 最左侧,是Beats,它主要是用于收集日志的,比如这个Filebeat它的底层是用erlang语言写的,性能非常好,其实我们的……