消息队列-kafka
Spring Kafka提供了许多配置选项，你可以根据需要进行配置，例如设置消费者组、自定义序列化器等。文件中添加Spring Kafka的依赖。在Spring Boot项目的。文件中配置Kafka的连接信息。来发送消息到Kafka主题。
消息队列—RabbitMQ如何保证消息可靠性？
我们的生产者发送消息之后可能由于网络闪断等各种原因导致我们的消息并没有发送到MQ之中，但是这个时候我们生产端又不知道我们的消息没有发出去，这就会造成消息的丢失。到这一步基本都是一些很小概率的问题了，比如MQ突然宕机了或者被关闭了，这种问题就必须要对消息做持久化，以便MQ重新启动之后消息还能重新恢复过
Hadoop-3.3.0-Centos7安装详解
这里是将JDK添加到user_hbase用户的环境变量中，执行“vi ~/.bash_profile”命令，打开.bash_profile文件，在文件底部添加如下内容即可。配置IP映射，将三台虚拟机的IP地址与对应的主机名进行映射，便于后续可以直接通过主机名访问对应的主机，这里以虚拟机node1为例
Kafka Stream入门
Kafka Streams是Apache Kafka的一个库，用于构建流式处理应用程序和微服务。它允许你以高吞吐量、可伸缩、容错的方式处理实时数据流。Kafka Streams专为易用性设计，可以直接在你的应用程序中嵌入使用，不需要单独的处理集群。它提供了一种简洁的方式，使得处理数据流和变换数据流变
Kafka问题纪要
和 MQ TT 的事务定义一样都是 3 种。（1）最多一次: 消息不会被重复发送，最多被传输一次，但也有可能一次不传输（2）最少一次: 消息不会被漏发送，最少被传输一次，但也有可能被重复传输.（3）精确的一次（Exactly once）: 不会漏传输也不会重复传输,每个消息都传输被一次而且仅仅被传输
什么是分布式？ Zookeeper与Dubbo-admin的使用
分布式系统是若干独立计算机的集合，这些计算机对于用户来说就像单个相关的系统；分布式系统是由一组通过网络进行通信、为了完成共同的任务而协调工作的计算机节点组成的系统。分布式系统的出现是为了使用廉价的、普通的机器完成单个计算机无法完成的计算、存储任务。其目的是利用更多的机器，处理更多的数据。
分布式监控Skywalking安装及使用教程（保姆级教程）
本文主要讲解分布式链路追踪监控系统Skywalking的安装及使用教程，从0到1，图文并茂的保姆级教程。SkyWalking是一款用于分布式系统跟踪和性能监控的开源工具。它可以帮助开发人员了解分布式系统中不同组件之间的调用关系和性能指标，从而进行故障排查和性能优化。它支持多种语言和框架，包括Java
RabbitMQ实现即时通讯居然如此简单！连后端代码都省得写了？
有时候我们的项目中会用到即时通讯功能，比如电商系统中的客服聊天功能，还有在支付过程中，当用户支付成功后，第三方支付服务会回调我们的回调接口，此时我们需要通知前端支付成功。最近发现RabbitMQ可以很方便的实现即时通讯功能，如果你没有特殊的业务需求，甚至可以不写后端代码，今天给大家讲讲如何使用Rab
ZooKeeper概述
Zab（ZooKeeper Atomic Broadcast）协议是ZooKeeper用来保证分布式数据一致性的核心协议。Zab是一种用于管理分布式系统中的主备模型的原子广播协议，确保所有的更新操作在集群中的所有机器上以相同的顺序执行，从而保证了数据的一致性。Zab主要用于ZooKeeper的领导者
spark
1，Spark是一种基于内存的快速、通用、可扩展的大数据分析计算引擎， 是当今大数据领域最活跃、最热门、最高效的大数据通用计算平台之一。
嬛嬛喊你学Spark、Scala的安装
目前，Spark生态系统已经发展成为一个包含多个子项目的集合，其中包含SparkSQL、Spark Streaming、GraphX、MLlib等子项目，Spark是基于内存计算的大数据并行计算框架。Spark得到了众多大数据公司的支持，这些公司包括Hortonworks、IBM、Intel、Clo
总结Rabbitmq的六种模式
AMQP 一个提供统一消息服务的应用层标准高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。RabbitMQ是AMQP协议的Erlang的实现。概念说明连接Connection一个网络连接，比如TCP/IP套接字连接。信道Channel多路复用连接中的一条独立的双向数据流通道。为
本地idea连接Centos7kafka操作
搭建完kafka，一般都是使用本地来链接虚拟机的，初次链接会出现各种神奇的问题，特此记录一下。首先，请先对生产者，消费者，topic有一个大概的认识。
重生之我在湖科职学Spark
重生之我在湖科职跟着宇将军学习Spark，好学，爱学，麦克阿瑟将军也说好!!!
Spark概述
Apache Spark是专为大规模数据处理而设计的快速通用的计算引擎。现在形成一个高速发展应用广泛的生态系统。Spark 主要有三个特点 :首先，高级 API 剥离了对集群本身的关注，Spark 应用开发者可以专注于应用所要做的计算本身。其次，Spark 很快，支持交互式计算和复杂算法。最后，Sp
Kafka安全模式之身份认证
SASL-PLAIN方式是一个经典的用户名/密码的认证方式，其中用户名和密码是以明文形式保存在服务端的JAAS配置文件中的，当客户端使用PLAIN模式进行认证时，密码是明文传输的，因此安全性较低，但好处是足够简单，方便我们对其进行二次开发，在0.10版本引入。在kafka身份认证的过程中，需要的pr
Kafka是如何保证消息不丢失
Apache Kafka通过多种机制来确保消息不丢失，包括数据复制（Replication）、持久化（Persistence）、确认机制（Acknowledgments）、幂等生产者（Idempotent Producer）、事务性发送（Transactional Messaging）等。以下是这些
Python图像处理【23】分布式图像处理
分布式处理可以将位于不同地点的、或具有不同功能的、或拥有不同数据的多台计算机通过通信网络连接起来，在控制系统的统一管理控制下，协调地完成大规模信息处理任务，利用分布式处理可以提高信息处理速度。在本节中，我们学习了如何使用 Dask 完成分布式图像处理，从而提高图像处理速度。
大数据培训之Zookeeper零基础-1
在大数据中，几乎所有的框架，它的安装都提供了三种模式单机模式：在一台服务器上安装，往往能够启动这个框架的部分服务伪分布式：在一台服务器上安装，但是利用多个线程模式分布式环境，能够启动这个框架的大部分甚至于服务分布式：在集群上安装，能够启动这个框架的所有服务现阶段，先安装单机模式，搞定所有的概念之后，
Kafka消费者构建失败的解决方法
在使用Kafka时，有时候我们可能会遇到"Failed to construct Kafka consumer"（无法构建Kafka消费者）的错误。在Java项目中使用Kafka时，需要在项目的构建配置文件（如Maven或Gradle）中添加正确的Kafka依赖。请确保您的应用程序能够与Kafka集
