RabbitMQ如何保证顺序消费
很多时候，消息的消费是不⽤保证顺序的，⽐如借助mq实现订单超时的处理。但有些时候，业务中可 能会存在多个消息需要顺序处理的情况，⽐如⽣成订单和扣减库存消息，那肯定是先执⾏⽣成订单的 操作，再执⾏扣减库存的操作。那么这种情况下，是如何保证消息顺序消费的呢？⾸先，为了效率，我们可以设置多个队列都来处理顺
Canal+Kafka实现MySQL与Redis数据同步（一）
在很多业务情况下，我们都会在系统中加入redis缓存做查询优化。如果数据库数据发生更新，这时候就需要在业务代码中写一段同步更新redis的代码。这种数据同步的代码跟业务代码糅合在一起会不太优雅，能不能把这些数据同步的代码抽出来形成一个独立的模块呢，答案是可以的。
大数据----33.hbase中的shell文件操作
这些是关于HBase在表中操作的命令。create: 创建一个表。list: 列出HBase的所有表。disable: 禁用表。is_disabled: 验证表是否被禁用。enable: 启用一个表。is_enabled: 验证表是否已启用。describe: 提供了一个表的描述。alter: 改变
毕业设计：python商品销售数据采集分析可视化系统 京东商品数据爬取+可视化 大数据 python（源码）✅
毕业设计：python商品销售数据采集分析可视化系统 京东商品数据爬取+可视化 大数据 python（源码）✅
一文详解Docker镜像
Docker镜像是一个轻量级、独立的、可执行的软件包，包含了运行应用程序所需的一切：代码、运行时环境、系统工具和库。Docker镜像是不可修改的，任何更改都会创建一个新的镜像就是把一个应用在硬盘上的文件、及其运行环境、部分系统函数库文件一起打包形成的文件包。这个文件包是只读的。镜像的名称组成：镜名称
搭建flink集群 —— 筑梦之路
一个 Flink 集群总是包含一个 JobManager 以及一个或多个 Flink TaskManager。Flink TaskManager 运行 worker 进程， 负责实际任务 Tasks 的执行，而这些任务共同组成了一个 Flink Job。Flink中的工作进程。通常在Flink中会有
基于Hologres+Flink的曹操出行实时数仓建设作者：林震｜曹操出行实时计算负责人
曹操出行创立于2015年5月21日，是吉利控股集团布局“新能源汽车共享生态”的战略性投资业务，以“科技重塑绿色共享出行”为使命，将全球领先的互联网、车联网、自动驾驶技术以及新能源科技，创新应用于共享出行领域，以“用心服务国民出行”为品牌主张，致力于打造服务口碑最好的出行品牌。作为一家互联网出行平台，
RabbitMQ交换机
Exchange在RabbitMQ中，生产者发送信息不会直接将消息投送到队列中，而是先将消息投递到交换机中，在由交换机转换到具体的队列，队列再将消息以推送或者拉取方式给消费者进行消费。生产者将消息发送到Exchange，由Exchange再路由到一个或多个队列中路由键（RoutingKey）生产者将
从 AutoMQ Kafka 导出数据到 Databend
作者：韩山杰Databend Cloud 研发工程师是使用 Rust 研发、开源的、完全面向云架构、基于对象存储构建的新一代云原生数据仓库，为企业提供湖仓一体化、计 算和存储分离的大数据分析平台。本文将介绍如何通过将数据从 AutoMQ for Kafka 导入 Databend。本文中提及的 Au
zookeeper 与eureka区别
zookeeper 与eureka区别
kafka（一：分区数据不均衡（数据倾斜），分区分配策略）
可以设置一个新的列，根据这个列进行hash。
【Kafka-3.x-教程】-【五】Kafka-监控-Eagle
Kafka-Eagle 框架可以监控 Kafka 集群的整体运行情况，在生产环境中经常使用。1）MySQL 环境准备Kafka-Eagle 的安装依赖于 MySQL，MySQL 主要用来存储可视化展示的数据。如果集群中之前安装过 MySQL 可以跨过该步。
深入理解Spring Kafka中@KafkaListener注解的参数与使用方式
Apache Kafka作为一个强大的消息代理系统，与Spring框架的集成使得在分布式应用中处理消息变得更加简单和灵活。Spring Kafka提供了注解，为开发者提供了一种声明式的方式来定义消息监听器。在本文中，我们将深入探讨注解的各种参数以及它们的使用方式，帮助读者更好地理解和使用Spring
Flink面试知识点：JobManager 和 Task
好迷茫，三本软件工程大三了，才刚学了Spring框架而且还没像样的项目，之前学校还学了python和安卓（很基础），以这个学习进度，下学期想找份像样的实习入行，俺也来试试牛爱网98男，身高173，体重65，河南人在上海读研，已签约上海某大厂，长相帅的一批。收到了快手offer，但开的不满意，想签一个
拥抱docker拥抱大数据——安装
一、Windows10专业版进入网址点击下载。
flink1.13环境搭建
flink1.13环境搭建
第二章 Eureka服务注册与发现
在传统的rpc远程调用框架中，管理每个服务与服务之间依赖关系比较复杂，管理比较复杂，所以需要使用服务治理，管理服务于服务之间依赖关系，可以实现服务调用、负载均衡、容错等，实现服务发现与注册。
Spark基础学习--基础介绍
Spark是可以处理大规模数据的统一分布式计算引擎。
SparkStreaming与Kafka整合
Receiver方式基于kafka的高级消费者API实现（高级优点：高级API写起来简单；不需要去自行去管理offset，系统通过zookeeper自行管理；不需要管理分区，副本等情况，系统自动管理；消费者断线会自动根据上一次记录在 zookeeper中的offset去接着获取数据；高级缺点：不能自
【大数据】安装 Zookeeper 单机版
点击 Download 即可下载，这里我们选择的版本是 3.5.10，下载之后扔到服务器上。由于 Zookeeper 是基于 Java 语言编写的，所以还需要安装 JDK，这里我使用的是 JDK1.8，都已经已经安装好了，并配置了环境变量。
