ZooKeeper 的四种 Znode （数据节点）类型
ZooKeeper 提供了四种类型的 Znode（数据节点），每种类型都有其特定的用途和特性。
ZooKeeper 的3种部署模式
Apache ZooKeeper 作为分布式系统中的重要协调服务，提供了多种部署模式以满足不同需求。以下是 ZooKeeper 的三种主要部署模式。
Hadoop 简介（五）
Hadoop是一个由Apache基金会所开发的分布式系统基础架构。用户可以在不了解分布式底层细节的情况下，开发分布式程序。充分利用集群的威力，解决海量数据的存储及海量数据的分析计算问题。广义上的Hadoop是指Hadoop的整个技术生态圈；狭义上的Hadoop指的是其核心三大组件，包括HDFS、YA
MQTT之NanoMQ基本使用及MQTTX客户端使用
MQTT是一种轻量级的协议，基于发布 /订阅模式的消息传输协议， MQTT 目前是物联网传输协议标准。和其他的消息队列一样（kafka、rabbitMQ、rovketMq等），只是协议比较轻，资源占用小等优点适用于物联网边缘设备的通信，数据传输。
RabbitMQ的安装
rabbitmq的安装
Zookeeper的ZAB协议原理详解
如何保证数据一致性。Paxos，吸收了主从。zk = 数据模型+Watch机制zab zookeeper原子广播协议。
kafka基础概念二
但是有一个问题，如果说这个topic中的消息非常非常多，多到需要几T来存，因为消息是会被保存到10g日志文件中的。集群中有多个broker，创建主题时可以指明主题有多个分区(把消息拆分到不同的分区中存储)，可以为分区创建多个副本，不同的副本存放在不同的broker里。副本是为了为主题中的分区创建多个
RabbitMQ 和 Kafka有什么异同?
RabbitMQ 和 Apache Kafka 是两种非常流行的分布式消息传递系统，它们各有特点和适用场景。
分布式项目中，Zookeeper、Nacos和Eureka作为注册中心
分布式项目就用三个注册中心，Zookeeper、Nacos和Eureka，差别就是AP和CP协议用的不同和性能在某一方面突出。在分布式项目中，Zookeeper、Nacos和Eureka作为注册中心，各自在CAP理论（一致性、可用性、分区容错性）的支持、性能以及其他方面存在显著的差异。
一文带你学会zookeeper（了解、安装、集群、使用）
1、zookeeper是一个开源的分布式的服务协调框架（Apache项目）2、zookeeper从设计模式的角度来理解：是一个基于观察者模式的分布式服务管理框架，他负责存储和管理大家都关心的数据，然后接收观察者的注册，一旦这些数据发生变化，zookeeper就将负责通知已经在zookeeper是哪个
Kafka系列之如何提高消费者消费速度
在实际开发过程中，如果使用Kafka处理超大数据量(千万级、亿级)的场景，Kafka消费者的消费速度可能决定系统性能瓶颈。
大数据-59 Kafka 高级特性 消息发送03-自定义拦截器、整体原理剖析
上一节研究了Kafka的序列化器、自定义序列化器、分区器、自定义分区器。本节研究Kafka拦截器，自定义拦截器、整体原理剖析附图片。实现ProducerInterceptor接口在的设置中定义自定义的拦截器（上一节 大数据 Kafka 58点击跳转借用我们刚才实现的 User 类，这里就不再写了。
Spark数据倾斜解决产生原因和解决方案
在对RDD执行shuffle算子时，给shuffle算子传入一个参数，比如reduceByKey(1000)，该参数就设置了这个shuffle算子执行 时shuffle read task的数量，即Spark.sql.shuffle.partitions，该参数代表了shuffle read tas
Docker拉取Rabbitmq镜像及后端项目结合
链接: https://pan.baidu.com/s/1HE8FN7zAoz1IJmkr-cNrPw?pwd=65nu 提取码: 65nu。1、将tar包随便导入一个临时文件夹中，直接复制粘贴，这里是导入到tmp文件夹中。1.2.3 配置application.yaml,连接RabbitMQ。1、
一文搞懂Kafka中的listeners配置策略
1. listeners中的plaintext controller external是什么意思？2. Kraft模式下controller和broker有何区别？
Kafka服务端日志详解
进入到上方配置文件中指定的目录下查看，topic的数据都是以topic名 + partition下标的命名方式保存的我们现在进入其中一个partition目录.index日志索引文件，采用的稀疏索引提高查询效率，记录的是消息偏移量offset 和 该消息在.log文件中的位置position.log
三十八、大数据技术之Kafka3.x（1）
Kafka是由Apache软件基金会开发的一个开源流处理平台，由Scala和Java编写。Kafka是一种高吞吐量的分布式发布订阅消息系统，它可以处理消费者在网站中的所有动作流数据。这种动作（网页浏览，搜索和其他用户的行动）是在现代网络上的许多社会功能的一个关键因素。这些数据通常是由于吞吐量的要求而
RabbitMQ如何保证生产者发送消息可靠？
当消费者处理消息结束后，应该向RabbitMQ发送一个回执，告知RabbitMQ自己消息处理状态。如果是由于其他原因导致的失败，RabbitMQ还支持生产者确认机制，当发生消息到MQ时会返回一个ACK的回执，如果发送失败会返回一个NACK的回执。当消费者出现异常后，消息会不断地重新入队到队列，再重新
分布式锁：Mysql实现，Redis实现，Zookeeper实现
通过自己定义一个锁表，并且定义一个不可重复的列，然后多个线程通过插入同一个数据来判断是否获取到锁，而释放锁的操作则是删除这条数据，通过自己实现这一过程，可以实现更灵活的分布式锁机制。
