Docker-Compose部署RabbitMQ
单机部署rabbitmq高可用集群模式
如何在rabbitmq中实现一个生产者，多个消费者，多个消费者都能收到同一条消息
如何在rabbitmq中实现一个生产者，多个消费者，多个消费者都能收到同一条消息场景：用户登录，邀请其它用户进行视频会议，收到邀请的用户进入会议rabbitmq实现思路：选型：发布订阅模式（Publish/Subscribe）一个生产者，多个消费者，每一个消费者都有自己的一个队列，生产者没有将消息直
Hadoop集群完全分布式搭建
hadoop集群分布式的搭建
Docker部署单节点Kafka
Docker安装Kafka单节点
kafka中topic的创建和查询
kafka topic
大数据常见术语
大数据常见术语一览主要内容包含以下（收藏，转发给你身边的朋友）雪花模型、星型模型和星座模型事实表维度表上钻与下钻维度退化数据湖UV与PV画像ETL机器学习大数据杀熟SKU与SPU即席查询数据湖数据中台ODS，DWD，DWS，DWT与ADST0与T+1用户画像用户画像又称用户角色，作为一种勾画目标用户
hadoop格式化时报错
Re-format filesystem in Storage Directory root= /data/hadoop/hdfs/name; location= null ? (Y or N)
多图详解 kafka 生产者消息发送过程
整个生产者客户端是由主线程和 Sender 线程协调运行的, 主线程创建消息, 然后通过 拦截器、元信息更新、序列化、分区器、缓存消息等等流程。然后 Sender 线程在初始化的时候就已经运行了,并且是一个 while 循环。Sender 线程里面主要工作是：去消息累加器里面获取有哪些 Node 是
RabbitMQ：订阅模型-消息订阅模式
订阅模型-消息订阅模式，也可以称为广播模式，生产者将消息发送到 Exchange，Exchange 再转发到与之绑定的 Queue中，每个消费者再到自己的 Queue 中取消息。RabbitMQ 单生产单消费模型主要有以下五个角色构成：生产者（producer/ publisher）：一个发送消息的
如何用Know Streaming来查询Kafka的消息
Kafka的消息查看功能算是一个呼声比较高的需求了。但是它目前还并不能像RocketMq那样比较友好的对消息做一些复杂查询操作。目前KnowStreaming的实现方式是使用Consumer客户端来拉取数据Know Streaming脱胎于互联网公司内部多年的Kafka运营实践经验，通过0侵入、插件
Kafka之Consumer使用与基本原理
前置内容Kafka生产者：juejin.cn/post/709417…Kafka Consumer基本概念：juejin.cn/post/709641…Java SDK 基本使用Consumer就是负责从Kafka集群中消费消息数据的应用程序，自 Kafka 0.9 版本提供了Java版本的Cons
rabbitMq实现延迟队列
业务场景：1.生成订单30分钟未支付，则自动取消，我们该怎么实现呢？2.生成订单60秒后,给用户发短信1 安装rabbitMqwindows安装ubuntu中安装2 添加maven依赖 <!-- https://mvnrepository.com/artifact/org.springf
Kafka架构篇 - 多副本机制
本文解析Kafka的多副本机制。
RabbitMQ之延迟队列
介绍了RabbitMQ的延迟队列
kafka详解
kafka的传统定义：kafka是一个分布式的基于发布\订阅模式的消息队列，主要用于大数据实时处理领域kafka的最新概念：kafka是一个开源的分布式事件流平台，（80%的公司都在用），用于高性能数据管道、流分析、数据集成和关键任务应用（1）生产者：向kafka集群发送数据（2）broker：启动
HBase Region 简介和建议数量&大小
建议分配合理的region数量，根据写请求量的情况，一般20-200个之间，可以提高集群稳定性，排除很多不确定的因素，提升读写性能。所以，如果一个HRegion中Memstore过多，而且大部分都频繁写入数据，每次flush的开销必然会很大，因此我们也建议在进行表设计的时候尽量减少ColumnFam
rabbitmq 怎么实现延迟消息队列？
RabbitMQ的Queue可以配置x-dead-letter-exchange 和x-dead-letter-routing-key（可选）两个参数，如果队列内出现了dead letter，则按照这两个参数重新路由。RabbitMQ可以针对Queue和Message设置 x-message-tt，
kafka介绍（一）
这个部分，需要简单的解答一下，其实MQ就是消息队列，那么本质上，就是一个 FIFO的队列数据结构。因此，早期的使用方法，都是启动一个线程发送消息，写入消息队列，作为消息缓存，然后再启动一个线程消费消息。早期的windows程序（桌面程序）的设计方法。后期，随着分布式微服务的快速发展，消息这个东西变成
Kafka 面试题（2022）
有关kafka的面试题最新整理
分布式注册中心ZooKeeper、Eureka、 Nacos
分布式注册中心出现，ZooKeeper,Eureka,Nacos的比较
