Kafka之Producer网络传输
我们首先回想一下Producer消息发送的整体流程客户端线程会不断地写入数据，当前线程并不会阻塞，而是马上返回。这个时候消息被Producer放在了缓存内，消息并没有真正发送出去Producer内部为每个Partition维护了一个RecordBatch的队列，先进先出的模式，统称为RecordAc
RabbitMQ的安装和使用
通过上面简单的示例，我们在SpringBoot工程中引入spring-boot-starter-amqp模块，进行简单配置就完成了RabbitMQ的消息生产和消费的开发内容。下面我们通过在SpringBoot项目中集成RabbitMQ，并实现一个简单的发送、接收消息的例子来对RabbitMQ有一个只
kafka可视化工具搭建之kafdrop
Kafdrop 是一个用于查看 Kafka 主题和浏览消费者组的 Web UI。该工具显示代理、主题、分区、消费者等信息,并且可以预览topic消息。
零拷贝原理+kafka中的零拷贝
零拷贝原理+mmp优化零拷贝+sendfile优化零拷贝+kafka中的零拷贝
zookeeper之节点基本操作(二）（头歌）
创建/zknode持久节点（节点数据为ZK），ACL设置为用户testZK的密码认证，用户testZK对该节点拥有读，写，管理权限。使用客户端（zkCli.sh）连接客户端（IP：127.0.0.1，端口号：2181）。使用客户端（zkCli.sh）连接客户端（IP：127.0.0.1，端口号：21
(Kafka源码三)Kafka的缓存机制
本文主要讲解了线程添加消息(append()方法源码)到RecordAccumulator的源码流程，以及在添加的过程中所涉及到内存的申请与释放的源码分析，最后介绍了RecordAccumulator通过CopyOnWriteMap实现的batches,从而实现了读写分离与高并发读的能力。下一章将从
毕设开源 大数据电影数据分析与可视化系统
今天学长向大家介绍一个机器视觉的毕设项目🚩基于大数据的电影数据分析与可视化系统毕业设计 大数据电影评论情感分析。
RabbitMQ——解决分布式事务问题，RabbitMQ的重要作用之一！！！通过可靠生产和可靠消费来完美解决！
分布式事务是指涉及多个独立的计算机系统（也称为节点或参与者）之间的事务处理。在分布式系统中，每个节点可能各自拥有自己的数据存储和事务管理机制。分布式事务的目标是保证在跨多个节点执行的一系列操作可以以一致和可靠的方式执行和提交，即使在面对故障或并发操作时也能保持数据的完整性和一致性。实现分布式事务可以
Zookeeper的数据结构以及常用命令使用
根目录中存在子目录，子目录中包含子文件，数据都在子文件中存储，而Zookeeper是在根节点下包含很多子节点，但是每一个节点都可以存储自己的一些数据和当前节点的信息，允许存储的数据大小为1M。Zookeeper的数据结构和标准的Unix文件系统类似，都存在一个（/）根，在Unix中数据结构被称为目录
Spark的易用性：易用性工具和实践
1.背景介绍1. 背景介绍Apache Spark是一个开源的大规模数据处理框架，它提供了易用性工具和实践，以便开发人员可以更轻松地处理大量数据。Spark的易用性是其吸引人的特点之一，因为它允许开发人员在短时间内构建和部署大规模数据处理应用程序。在本文中，我们将探讨Spark的易用性工具和实践，并
离线数仓-数据仓库系统
数据模型就是数据组织和存储方法，它强调从业务、数据存取和使用角度合理存储数据。只有将数据有序的组织和存储起来之后，数据才能得到高性能、低成本、高效率、高质量的使用。高性能：良好的数据模型能够帮助我们快速查询所需要的数据。低成本：良好的数据模型能减少重复计算，实现计算结果的复用，降低计算成本。高效率：
Flink窗口函数
看过上面3个案例，可以发现增量聚合函数ReduceFunction和AggregateFunction都是数据来一条处理一条，而全窗口函数ProcessWindowFunction则是在窗口结束的时候才执行计算，因此process的效率相对更低。但是process的优点在于它可以得到上下文信息，因此
分布式 SpringCloudAlibaba、Feign与RabbitMQ实现MySQL到ES数据同步
MySQL 数据 如何同步到ES，重磅来袭，面试高频 ？ 一文彻底搞定！
【大数据】大数据概论与Hadoop
纯干货！十分钟，快速聊明白大数据概论和Hadoop。
RabbitMQ3.13.x之一_WindowServer2019中安装RabbitMQ详细教程
RabbitMQ3.x之一_WindowServer2019中安装RabbitMQ详细教程,包括ErLang与RabbitMQ安装及环境变量配置
docker更换国内源加速
1、在/etc/docker/下修改（如有）或创建daemon.json文件。更换docker的国内镜像源，可以加快镜像的下载。3、重启docker。4、查看是否更换成功。
HBase安装，配置，启动，检查
HBase安装，配置，启动，安装检验 (进程查看，web UI界面，客户端交互)
docker-compose部署kafka、SASL模式(密码校验模式)
注意点：192.168.1.20 是宿主机的ip。
spark和scala环境安装与部署，有手就行
source /etc/profile使环境变量生效，接着scala -version查看是否安装成功，出现画线版本号即为成功。解压安装包 tar -zxvf /opt/scala2.12.12.tgz -C /opt/9.查看spark是否安装成功 返回主目录下输入spark-submit -
RabbitMQ的常见工作模式
Topic类型与Direct相比，都是可以根据 RoutingKey 把消息路由到不同的队列。只不过 Topic 类型Exchange可以让队列在绑定 Routing key 的时候使用通配符！
