大数据

DataInLong任务切换实践:从Kafka-A到Kafka-B的数据迁移指南

个人名片 🎓作者简介:java领域优质创作者 🌐个人主页:码农阿豪 📞工作室:新空间代码工作室(提供各种软件服务) 💌个人邮箱:[2435024119@qq.com] 📱个人微信:15279484656 &#x1f310

Dropwizard与ZooKeeper集成:分布式配置管理

Dropwizard与ZooKeeper集成:分布式配置管理 【免费下载链接】dropwizard A damn simple library for building production-ready RESTful web services. 项目地址: 你还在为分布式系统中的

基于 Flink + Kafka + Flask + ECharts 构建企业级网约车实时监控系统

基于Flink的网约车实时大数据监控系统:从0到1的全栈实战 文章目录 基于Flink的网约车实时大数据监控系统:从0到1的全栈实战 前言 一、项目背景与需求分析 1.1 核心需求 1.2 技术挑战 二、技术架构设计 2.1 整体架构 2.2 技术栈选型 2.3 系统架构图 三、核心功能实现 3.1 环境搭建:D

Zookeeper的监听机制及原理解析

系列文章目录手把手教你安装Zookeeper 及可视化插件ZooInspector、ZKUI Zookeeper入门篇,了解ZK存储特点 使用Zookeeper的监听及原理解析 系列文章目录 前言 一、监听机制的基本概念 二、Zookeeper监听原理 1. 事件类型 2. 监听模式与监听器类型 (1)监听模式 (2&#x

Rabbitmq在死信队列中的队头阻塞问题

死信队列(Dead-Letter Queue,DLQ)是 RabbitMQ 处理无法正常消费消息的核心机制,但队头阻塞(Head-of-Line Blocking) 是其高频踩坑点——队列中首个无法被消费的消息会阻塞后续所有消息的处理,即使后续消息本身是合法可消费的。本文从成因、场景、危害、解决方案全

Hadoop

HDFSHadoop Distributed File System(分布式文件系统)优点:1.高容错性:数据自动保存多个副本,通过增加副本的形式,提高容错性。并且当某个副本丢失的时候,可以自动恢复。2.适合处理大数据:可以存海量数据,GB级别,TB级别甚至P

时序数据库选型指南:基于大数据视角的IoTDB应用优势分析详解!

目录一、时序数据库选型的基本原则1.1 数据特征与需求分析1.1.1 数据规模与写入负载1.1.2 查询需求1.1.3 数据保留与归档策略1.1.4 系统扩展性与高可用性1.2 技术架构与系统性能评估1.2.1 写入性能1.2.2 查询性能1.2.3 数据压缩能力1.2.4 高可用性与灾备能力1.3 成本与TCO(总拥有成本)二、IoTDB的优势与应用2.1 IoTDB

2025最新版flink2.0.0安装教程(保姆级)

Flink支持多种安装模式。local(本地)——本地模式standalone——独立模式,Flink自带集群,开发测试环境使用standaloneHA—独立集群高可用模式,Flink自带集群,开发测试环境使用yarn——计算资源统一由Hadoop YARN管理,生产环境测试flink1.13 &#x

详解RabbitMQ高级特性之TTL

目录TTL添加配置常量类消息的TTL声明队列和交换机并绑定二者关系编写生产消息代码生产消息队列的TTL声明队列和交换机并绑定二者关系编写生产消息代码生产消息(消息无TTL)生产消息(消息有TTL)消息的TTL和队列的TTLTTL TTL(Time to Live, 过期时间), 即过期时间. RabbitMQ可以对消息和队列设置TTL.