下一代大数据分布式存储技术Apache Ozone初步研究
如果还在为HDFS上存储海量的小文件而烦恼，不烦多留意号称下一代分布式存储技术Apache Ozone，其诞生初衷就是解决HDFS面临棘手问题，本篇从了解其特性和总体架构，基于开发测试需求通过docker和docker-compose方式启动Ozone本地集群，最后通过命令行接口和兼容hadoop命
RabbitMQ
① 在 publisher 服务中编写 application.yml，(2) 在 publisher 服务中利用 RabbitTemplate。① 在 consumer 服务中编写 application.yml，(3) 在 publisher 中编写测试方法，向 itcast.(3) 在 pub
Kafka相关的一些基础概念
Kafka是一个分布式的基于发布/订阅模式的消息队列（Message Queue），主要应用于大数据实时处理领域。
Kafka概论
进来看看！相信我，一文能学会Kafka。
kafka 是如何清理过期数据
kafka 是如何清理过期数据
kafka消息监听
值得注意的是，上述代码是使用Spring Kafka提供的注解方式来创建Kafka消费者。通过该注解，您可以方便地定义多个消费者，并且框架会自动处理与Kafka的连接、消费消息等底层细节。注解可以订阅多个主题和分区，并指定每个分区的初始偏移量。groupId表示分组，不同组的消费者不是竞争关系。这段
调式源码解决 seata 报错 can not get cluster name 问题
整合seata，控制台报错查询文档，nacos添加了配置，就需要在yml文件上配置。添加后控制台还是报错。调式源码，找到报错代码位置，一步一步向上调试，找到分组事务无法设置的原因，最后发现分组事务是根据属性来设置。官方文档更新不及时的时候，这就需要我们调式源码的能力。前段时间一直在写解析源码的文章，
logstash同步数据从kafka到es集群
【代码】logstash同步数据从kafka到es集群。
kafka查看消息两种方式（命令行和软件）
①找到kafka安装文件夹②执行命令。
rabbitmq消息确认机制
默认是ack，consumer只要拿到消息就会自动确认，服务端就会删除queue中的消息，如果业务出现问题只有部分消息签收成功，剩余未签收的消息也会删除，为了能保存消息，需要设置为客户端手动确认签收。如果exchange有消息没有成功发送至queue，就会执行RuturnCallback，例：rou
Spring Boot如何实现分布式消息队列
在分布式系统中，消息队列是非常重要的一部分，可以帮助开发人员实现异步处理、解耦系统、提高系统可靠性等。本文介绍了使用 RabbitMQ 实现分布式消息队列的示例代码。在实际使用中，需要根据具体场景选择合适的工具和方案，并注意消息的传输性能和可靠性，确保系统的可靠性和性能。
RabbitMQ ---- Hello World
本节使用 Java 编写两个程序。发送单个消息的生产者和接收消息并打印出来的消费者。
Windows 环境下 Docker 安装伪分布式 Hadoop
将时区文件链接到本地时间文件上，以便系统能够正确地显示当前时间，防止系统重启后时区改变。输入下面命令可以看到时间和咱们时间不一样，需要同步一下不然以后可能会遇到一些问题。设置 ssh 开机自启，找到并打开文件/root/.bashrc。配置容器内的 root 用户密码，该密码可用于远程登录。我这里选
使用docker快速安装Kafka
快速安装kafka。
Redis实现分布式锁（SETNX）
本文详细介绍了什么是分布式锁、分布式锁的特征、应用场景；一步一步的手动实现分布式锁，分析其中需要特别注意的地方，带着大家理清其中的思路；相信对大家会有所帮助
【Kafka】【十三】生产者中的ack配置
在同步发送的前提下，⽣产者在获得集群返回的ack之前会⼀直阻塞。那么集群什么时候返回ack呢？下⾯是关于ack和重试（如果没有收到ack，就开启重试）的配置。
RabbitMQ一些常用的命令
这些命令可以用于获取 RabbitMQ 实例的各种状态信息，例如队列、交换器、连接、通道等的状态，从而帮助进行监控和管理 RabbitMQ 实例。更多的命令和选项可以通过。命令时，需要具有足够的权限，并且谨慎操作，以避免对 RabbitMQ 实例造成不必要的影响。以下是一些常用的 RabbitMQ
docker安装RabbitMQ教程(2023年最详细)
RABBITMQ_DEFAULT_USER：默认的用户名；如果需要安装其他版本在rabbitmq后面跟上版本号即可 docker pull rabbitmq:3.7.7-management。--hostname 主机名（RabbitMQ的一个重要注意事项是它根据所谓的 “节点名称” 存储数据，
Kafka
先进入kafka安装目录 bin下。
JAVA中Kafka配置
【代码】JAVA中Kafka配置。
