分布式
-
Zookeeper与Eureka的集成与应用
1.背景介绍 Zookeeper和Eureka都是分布式系统中常用的组件,它们各自具有不同的功能和应用场景。Zookeeper是一个开源的分布式协调服务,用于解决分布式系统中的一些…
-
Hadoop 在企业中的应用场景与案例分析
1.背景介绍 Hadoop 是一个开源的分布式文件系统和分析框架,它可以处理大量数据并提供高性能的计算能力。在企业中,Hadoop 已经成为一个重要的技术手段,用于处理和分析大规模…
-
RabbitMQ延时队列的实现原理和应用实例
一、延时队列应用场景 二、RabbitMQ实现原理 1、RabbitMQ 中的 TTL TTL 是 RabbitMQ 中一个消息或者队列的属性,表明一条消息或者该队列中的所有消息的…
-
Kafka详解及常见面试问题解析(值得珍藏)
点击下载《Kafka详解及常见面试问题解析(值得珍藏)》 1. 定义 Kafka是由Apache软件基金会开发的一个开源流处理平台,由Scala和Java编写。它是一种高吞吐量的分…
-
ClickHouse Keeper: 一个用 C++ 编写的 ZooKeeper 替代品
。 本文字数:9915;估计阅读时间:25 分钟 审校:庄晓东(魏庄) 本文在公众号【ClickHouseInc】首发 介绍 ClickHouse 是用于实时应用和分析的最快且资源…
-
Spark Streaming的DStream与窗口操作
实时数据处理已经成为当今大数据时代的一个重要领域,而Spark Streaming是Apache Spark生态系统中的一个关键模块,用于处理实时数据流。本文将深入探讨Spark …
-
Kafka:消费者消费失败处理-重试队列
kafka没有重试机制不支持消息重试,也没有死信队列,因此使用kafka做消息队列时,需要自己实 现消息重试的功能。 实现 创建新的kafka主题作为重试队列: 创建一个topic…
-
Kafka 安装部署-单节点
Kafka强依赖ZK,如果想要使用Kafka,就必须安装ZK,Kafka中的消费偏置信息、kafka集群、topic信息会被存储在ZK中。有人可能会说我在使用Kafk…
-
删除Kafka的Topic(提示:marked for deletion)
问题: 删除topic时标记删除marked for deletion但未真正的删除 解决方法: 1.修改server.properties,并重启kafka delete.to…
-
【分布式微服务专题】SpringSecurity OAuth2快速入门
目录 前言 阅读对象 阅读导航 前置知识 笔记正文 一、OAuth2 介绍 1.1 使用场景 *1.2 基本概念(角色) 1.3 优缺点 二、OAuth2的设计思路 2.1 客户端…
-
Kafka中的生产者如何处理消息发送失败的情况?
在Kafka中,生产者可以通过以下方式处理消息发送失败的情况: 同步发送模式(Sync Mode):在同步发送模式下,生产者发送消息后会阻塞等待服务器的响应。如果发送失败,生产者会…
-
rabbitmq 重试机制
RabbitMQ是一个开源的消息中间件,它提供了可靠的消息传递机制。当消息发送到RabbitMQ时,可能会出现一些问题,例如网络故障、消费者不可用等,导致消息无法成功发送或消费。为…
-
RabbitMQ死信交换机
目录 1.死信交换机介绍 2.TTL 3.延迟队列 4.消息堆积问题 5.惰性队列 6.代码实战 1.死信交换机介绍 当一个队列中信息满足下列情况之一时,可以成为死信(dead…
-
Hadoop精选18道面试题(附回答思路)
1.简述Hadoop1和Hadoop2的架构异同 HDFS HA(High Availablity) 一旦Active节点出现故障,就可以立即切换到Standby节点,避免了单点故…
-
Spark中的Driver、Executor、Stage、TaskSet、DAGScheduler等介绍
工作流程: Driver 创建 SparkSession 并将应用程序转化为执行计划,将作业划分为多个 Stage,并创建相应的 TaskSet。 Driver 将 TaskSet…
