分布式
-
Kafka可视化利器 KafkaTool 发送kafka消息
kafak是我们工作中常用的消息组件,今天在跟合作方联调的时候被告知上游没有准备好消息数据,没有办法从依赖方拿到消息但是我们还又想测试自己写的消息消费的代码,怎么办呢?常规的做法就…
-
Kafka篇——Kafka集群Controller、Rebalance和HW的详细介绍,保姆级教程!
Controller 一、概念 在Kafka中,Controller是Kafka集群中的一个角色,负责管理集群的元数据、分区分配、副本管理等功能。 Controller的主要职责包…
-
Hadoop启动时出现错误:Cannot execute /home/hadoop/libexec/hadoop-config.sh.
出现错误: Hadoop启动时出现错误:Cannot execute /home/hadoop/libexec/hadoop-config.sh. 原因分析 'ERROR: Can…
-
Zookeeper+Kafka概述
一 Zookeeper 1.1 Zookeeper定义 Zookeeper是一个开源的、分布式的,为分布式框架提供协调服务的Apache项目。 1.2 Zookeeper特点 Zo…
-
kafka高吞吐、低延时、高性能的实现原理
作者:源码时代-Raymon老师 Kafka的高吞吐、低延时、高性能的实现原理 Kafka是大数据领域无处不在的消息中间件,目前广泛使用在企业内部的实时数据管道,并帮助企业构建自己…
-
Hadoop分布式文件系统(二)
目录 一、Hadoop 1、文件系统 1.1、文件系统定义 1.2、传统常见的文件系统 1.3、文件系统中的重要概念 1.4、海量数据存储遇到的问题 1.5、分布式存储系统的核心属…
-
奇技淫巧:如何给项目中的RabbitMQ添加总开关
本文主要分享了如何给项目中的RabbitMQ添加总开关,通过简单配置开/关RabbitMQ。 一、需求背景 SpringBoot项目里使用了RabbitMQ,但某些场景下,不希望项…
-
【分布式流控组件 Sentinel 快速入门】——图文详解操作流程
💧 分布式流控组…
-
ZooKeeper 高级应用
更好的阅读体验 \huge{\color{red}{更好的阅读体验}} 更好的阅读体验 概述 ZooKeeper 是 Apache 软件基金会的一个软件项目,它为大型分布式计算提供…
-
Spark 图计算ONEID 进阶版
0、环境信息 本文采用阿里云maxcompute的spark环境为基础进行的,搭建本地spark环境参考搭建Windows开发环境_云原生大数据计算服务 MaxCo…
-
Hadoop作业篇(一)
一、选择题 1. 以下哪一项不属于Hadoop可以运行的模式__C____。 A. 单机(本地)模式 B. 伪分布式模式 C. 互联模式 D. 分布式模式 C. 互联模式 不属于H…
-
Vmware虚拟机Centos6.5+Hadoop 完全分布式集群
一、环境:Vmware16+三台cent0s6.5 二、步骤 ROOT 用户操作(三台虚拟机都要操作,下面是以 HMaster 的操作截图) 一、配置 IP 和网关 1.在 wi…
-
09-zookeeper
一 Zookeeper概念 1 集中式到分布式 1.1 单机架构 一个系统业务量很小的时候所有的代码都放在一个项目中就好了, 然后这个项目部署在一台服务器上,整个项目所有的服务都由…
-
flink源码分析之功能组件(五)-高可用组件
简介 本系列是flink源码分析的第二个系列,上一个《flink源码分析之集群与资源》分析集群与资源,本系列分析功能组件,kubeclient,rpc,心跳,高可用,sl…
-
kafka如何实现延迟队列来实现延迟消费
在Kafka中实现延迟队列来实现延迟消费的最有效率的方式是使用Kafka的时间戳和时间戳索引功能。 以下是使用Java实现Kafka延迟队列的详细步骤: 创建一个专门用于延迟消费的…
