Kafka经典三大问：数据有序丢失重复
的情况下，是有可能存在消息丢失的情况的，因为producer收到leader写入成功的通知就认为推送成功，但实际上leader副本在把消息同步到follower副本的时候失败了，这时候消息就丢失了。例如消费者已经获取到这个数据，并且提交了offset，但后续在对数据进行业务操作的时候挂掉了，导致数据
注册中心 —— SpringCloud Netflix Eureka
Eureka 是一个基于 REST 的服务发现组件，SpringCloud 将它集成在其子项目 spring-cloud-netflix 中，以实现 SpringCloud 的服务注册与发现，同时提供了负载均衡、故障转移等能力，目前 Eureka2.0 已经不再维护，故不推荐使用Eureka Ser
【Kafka】docker部署Kafka集群
docker部署Kafka集群
Kafka的保姆级简易安装启动、关闭注意事项、简单使用
kafka关闭是切记尽量！不要直接关闭命令行窗口，此为暴力关闭，可能会导致kafka无法对日志文件的解锁，再启动的时候无法启动成功。且就算关闭也要按照先关闭kafka再关闭zookeeper的顺序。：这个zookeeper.connect=localhost:2181和log.dirs=./logs
centos7安装zookeeper的环境变量配置导致用户登录不了系统
废话不多说，我修改的/etc/profile,如果这个文件改错会造成所有用户都登录不了系统。2.修改或者删掉被你改动的部分，保存，退出，重启就OK了。第一步：解决进不了系统。第二步：修改为正确文件。
RabbitMq-发布确认高级（避坑指南版）
rabbitMq-消息确认（高级）避坑指南篇~参考文章可以解决“无法触发回调”的问题
ListenerExecutionFailedException消费rabbitMQ队列中消息出错导致刷屏
尚医通项目的ListenerExecutionFailedException消费rabbitMQ队列中消息出错导致刷屏
Kafka系列之：Kraft模式
Kafka系列之：Kraft模式
rabbitMQ杂记
消息队列中间件是分布式系统中重要的组件，主要解决应用耦合异步消息流量 削锋等问题实现高性能，高可用，可伸缩和最终一致性：解耦：异步：削峰：常见类型：强调进群节点中数据一致。在分布式中一致性又包括强一致性和弱一致性，强一致性就是指在任何时刻任何节点看到的数据都是一样的；弱一致性一般实现是最终一致性，即
【Hibench 】完成 HDP-Spark 性能测试
HiBench是Intel推出的一个大数据基准测试工具，可以帮助评估不同的大数据框架在速度、吞吐量和系统资源利用方面评估不同的大数据框架的性能表现。它包含一组Hadoop、Spark和流式WorkLoads，包括Sort、WordCount、TeraSort、Repartition、Sleep、SQ
Spring Cloud - Eureka原理、注册、搭建、应用（全过程详解）
上一章我们讲到，利用 RestTemplate 发送 http 请求时，将 url 写成了 "http://localhost:8081/user/" + order.getUserId() ，这无疑将 url 写死了，？这只是其中一个背景，总的来讲，有以下三种原因：服务消费者该如何获取服务提供者的
SpringBoot基于Zookeeper实现分布式锁
参考自SpringBoot集成Curator实现Zookeeper基本操作Zookeeper入门本篇的代码笔者有自己运行过，需要注意组件的版本号是否兼容，否则会有比较多的坑。
中间件 -zookeeper
首先，在分布式架构中，任何的节点都不能以单点的方式存在，因此我们需要解决单点的问题。常见的解决单点问题的方式就是集群大家来思考一下，这个集群需要满足那些功能？集群中要有主节点和从节点（也就是集群要有角色）集群要能做到数据同步，当主节点出现故障时，从节点能够顶替主节点继续工作，但是继续工作的前提是数据
【RabbitMQ】消息队列-RabbitMQ篇章
所以发送消息的时候没有设置交换机，rabbitmq发送消息一定会有默认一个交换机，并且消息不是直接到队列当中的，而是由交换机根据路由键发送消息到绑定的队列。当前可以看到安装镜像的时候可以设置用户名，密码，ip。ACK相当于手动的把消息处理了，这个时候就会把消息从队列剔除，导致消息丢失。消费者和生产者
大数据Flink（五十六）：Standalone伪分布环境（开发测试）
需要注意的是，“flink-${user}-standalonesession-${id}-${hostname}”和“flink-${user}- taskexecutor-${id}-${hostname}”都带有“${id}”，“${id}”表示本进程在本机上该角色（JobManager 或
Ambari自动部署hadoop
Apache Ambari项目旨在通过开发用于配置，管理和监控Apache Hadoop集群的软件来简化Hadoop管理.Ambari提供了一个由RESTful API支持的直观，易用的Hadoop管理Web Ul。Ambari使系统管理员能够:提供Hadoop集群Ambari提供了跨任意数量的主机
hive窗口函数计算累加值
rows是物理窗口，是哪一行就是哪一行，与当前行的值（order by key的key的值）无关，只与排序后的行号相关，就是我们常规理解的那样。range是逻辑窗口，与当前行的值有关（order by key的key的值）,在key上操作range范围。简要：如果当前行的值有重复的，range会默认
elasticsearch7设置用户名和密码
elasticsearch7用户名密码设置
ZooKeeper 安装
ZooKeeper 安装
实现高效消息传递：使用RabbitMQ构建可复用的企业级消息系统
RabbitMQ是一个在 AMQP(高级消息队列协议)基础上完成的，可复用的企业消息系统，是当前最主流的消息中间件之一。由erlang开发的AMQP（Advanced Message Queue 高级消息队列协议 ）的开源实现，由于erlang 语言的高并发特性，性能较好，本质是个队列，FIFO 先
