HADOOP的配置
hadoop的配置详解
RabbitMQ的基本使用，进行实例案例的消息队列
RabbitMQ是一种开源的消息代理和队列服务器，用于通过简单和可扩展的方式在分布式系统中传递消息。它实现了高级消息队列协议（AMQP）。服务之间最常见的通信方式是直接调用彼此来通信,消息从一端发出后立即就可以达到另一端,称为即时消息通讯(同步通信)消息从某一端发出后,首先进入一个容器进行临时存储,
使用python的pika链接rabbitMq断裂
只要是使用pyhon的pika都会出现这个问题，因为pika本身是没有心跳机制的（你用java的话是没问题的）比如我们执行一个很长的任务的时候，执行结束ack确认发现确认失败，mq都断了。解决方案，在代码里加入这一段，守护线程。让他定时发送心跳，这样就不会断开链接了。
Zookeeper(持续更新)
官方文档上这么解释zookeeper，它是一个分布式协调框架，是Apache Hadoop 的一个子项目，它主要是用来解决分布式应用中经常遇到的一些数据管理问题，如：统一命名服务、状态同步服务、集群管理、分布式应用配置项的管理等。
Message queue 消息队列--RabbitMQ 【基础入门】
1.1使用消息队列的优点：服务之间最常见的通信方式是直接调用彼此来通信,消息从一端发出后立即就可以达到另一端,称为即时消息通讯(同步通信) 消息从某一端发出后,首先进入一个容器进行临时存储,当达到某种条件后,再由这个容器发送给另一端,称为延迟消息通讯(异步通信)如下：如果我们不使用MQ的话由订单直接
【大数据】Zookeeper 数据写入与分布式锁
无论是 Zookeeper 自带的客户端 zkCli.sh，还是使用 Python（或者其它语言）实现的客户端，本质上都是连接至集群，然后往里面读写数据。那么问题来了，集群在收到来自客户端的写请求时，是怎么写入数据的呢？
深入理解 Flink（四）Flink Time+WaterMark+Window 深入分析
Event Time + WaterMark 是 Flink 处理乱序数据的有效机制，本章节将深入分析 Flink 的 Time 与 WaterMark，使读者对其有更为深刻的理解。
【Kafka】Kafka客户端认证失败：Cluster authorization failed.
1. kafka客户端是公司内部基于spring-kafka封装的2. spring-boot版本：3.x3. spring-kafka版本：2.1.11.RELEASE4. 集群认证方式：SASL_PLAINTEXT/SCRAM-SHA-5125. 经过多年的经验，以及实际验证，配置是没问题的，但
Spark-RDD详解
rdd中封装了各种算子方便进行计算，主要分为两类转化算子 对rdd数据进行转化计算得到新的rdd，定义了一个线程任务action执行算子 触发计算任务，让计算任务进行执行，得到结果触发线程执行的。
Rabbitmq的使用
mq作为常用的中间件，是被频繁使用的。根据技术选型有kafka,rabbitmq等等，如何进行技术选型是要根据实际情况来讲，可以参考。当前我们仅说rabbitmq。Rabbit应用在金融行业比较多，是因为它的可靠性比较好。
Kafka（七）可靠性
min.insync.replicas(默认值为1)代表了正常写入生产者数据所需要的最少ISR个数, 当ISR中的副本数量小于min.insync.replicas时，Leader停止写入生产者生产的消息，并向生产者抛出NotEnoughReplicas异常，阻塞等待更多的 Follower 赶上并
大数据开发之Zookeeper
它负责存储和管理大家都关心的数据，然后接受观察者的注册，一旦这些数据的状态发生变化，Zookeeper 就将负责通知这些已经在 Zookeeper 上注册的那些观察者做出相应的反应。
RabbitMq
首先，了解下什么是，这很重要，有些流程使用同步很合理，但是使用异步就会违反需求，就比如下单，用户下单后要先扣减余额，才能更新订单的支付状态，这两步操作只能是同步操作，因为第二步是否成功紧密关联第一步返回的结果。而修改完订单状态后的一系列不重要操作，则是可以进行异步处理，就比如更新订单状态、增加用户积
rabbitmq-常见七种消息队列-控制台界面管理-python-实现简单访问
通过使用rabbitmq技术，可以实现生产者和消费者模式，并实现两者的解耦，生产者负责通过交换机将数据存入队列，而消费者从队列中取数据，并执行相应的消息。可以用在服务器复杂耗时任务的并行计算中使用，与常用的web服务器（如apache等）解耦，提高服务器计算资源的利用效率。
Kafka详解及常见面试问题解析（值得珍藏）
Kafka是一个分布式消息队列，它对消息保存时根据Topic进行归类。发送消息者称为Producer，消息接受者称为Consumer。此外，Kafka集群由多个Kafka实例组成，每个实例（server）成为broker。无论是Kafka集群，还是Producer和Consumer都依赖于Zooke
RabbitMQ的基本使用&入门
RabbitMQ可以实现可靠的异步通信，解耦系统中的组件，以及处理高并发和大规模的消息流。它在许多领域，如微服务架构、日志处理、任务调度等方面都有广泛的应用RabbitMQ作为消息中间件，它允许应用程序之间通过消息进行通信。消息被发送到队列中，然后由消费者从队列中接收并处理。生产者是将消息发送到Ra
【Kafka】Kafka介绍、架构和概念
Kafka介绍、架构和概念
Failed to construct kafka producer
使用Notepad++打开，输入ip地址和kafka名称。将kafka信息输入到hosts文件中。
云消息队列 Kafka 版生态谈第一期：无代码转储能力介绍
为了提升研发效率，云消息队列 Kafka 版联合阿里云产品支持到无代码、全托管、Serverless 化的功能特性，支持从云消息队列 Kafka 版到 OSS 的转储。
Kafka 原理篇
作者：码哥字节今天我们来深入讲解 Kafka 的架构和实现原理。我将从架构和细节入手，以生动的图深入讲解 Kafka 的实现原理。我想很多同学之前可能已经看过很多 Kafka 原理相关的文章，但往往看时"牛逼"声连连，激情满满，总觉得自己又学习到了各种“吊炸天”的技术。但很多同学往往是不觉明厉，把文
