使用javaApi监控 kafka 集群的环境下消费组的积压信息
javaApi 监控 kafka 集群的环境下消费组的积压信息
linux下安装rabbitmq及踩坑总结
linux 安装rabbitmq
MQ（消息中间件）概述及 RabbitMQ 的基本介绍
MQ（消息中间件）概述及 RabbitMQ 的基本介绍
什么是EC, EC与多副本的对比分析
而在分布式存储系统中，HDFS（Hadoop Distributed File System）为了保证数据的可靠性默认数据存储策略是3副本，即在写入数据的时候，会占用该数据大小3倍的空间，这样就造成了大量的空间浪费。如果把n+m份数据分布在存储系统的不同节点上，那么任意小于等于m个节点故障（m份数据
RabbitMQ重复消费
造成RabbitMq重复消费的原因，以及如何解决RabbitMq的重复消费。
Hadoop大数据从入门到实战（二）分布式文件系统HDFS
头歌实践教学平台教学课堂大数据从入门到实战 - 第2章 分布式文件系统HDFS。
flink1.17.0 集成kafka，并且计算
这里只是做了一个简单的消费kafka的flink例子，消费成功后还可以通过sink发送出去，还可以用transform进行转换，这里后面再演示，如果不对的可以指出。
Windows环境下RabbitMQ的安装（安装过程以及解决安装过程的问题）
详细的介绍了Windows下安装RabbitMQ的过程、RabbitMQ管理插件的安装和常见的命令以及解决安装过程出现的问题
你好：Zookeeper
初次认识了Zookeeper，讲解了Zookeeper分布式集群搭建的过程，在搭建完成之后进行了Zookeeper shell API的学习，通过Shell API初次尝试Zookeeper，同时通过curator进行Java Api的尝试。此外Zookeeper也能够实现分布式锁，在这里进行了一个
kafka消费多个topic的使用
我们在业务中难免遇到一个kafka消费多个topic的消息，本文帮助大家如何在业务中用一个类消费多个topic消息。
第三章_基于zookeeper实现分布式锁
在这种羊群效应中，zookeeper需要通知1000个客户端，这会阻塞其他的操作，最好的情况应该只唤醒新的最小节点对应的客户端。在设置事件监听时，每个客户端应该对刚好在它之前的子节点设置事件监听，例如子节点列表为/lock/lock-0000000000、/lock/lock-0000000001、
Kafka消息队列核心概念以及部署
当系统架构中引入了消息队列，用户下单完成后向消息队列中发送一条消息数据后，就会返回给用户订单创建完成，此时仅仅花费50毫秒的时间，消息数据进入到消息队列后，会被分配到某一个队列中，需要与订单系统联动的系统，就会去消息队列中订阅这个队列，然后消费订单系统产生的消息数据，进行相应的业务逻辑处理。无Bro
【kafka】服务器命令行查询kafka信息消费情况
kafka-tool出问题的情况下，可以用命令行来查看kafka信息
【RabbitMQ教程】第七章 —— RabbitMQ - 发布确认高级
🐬初学一门技术时，总有些许的疑惑，别怕，它们是我们学习路上的点点繁星，帮助我们不断成长。🐟文章粗浅，希望对大家有帮助！💧下一篇 -->《RabbitMQ》
nacos的启动关闭命令
1.Nocas启动服务切换到bin目录，执行命令：[root@bogon bin]# sh startup.sh -m standalone后台运行[root@bogon bin]# nohup sh startup.sh -m standalone &2.Nacos关闭服务[root@bo
【Spark】Spark的常用算子
使用给定的函数对 RDD 的元素进行聚合，seqOp 计算在分区中初始值到中间结果的聚合计算，而 combOp 在节点上对中间结果进行聚合。: 返回对输入 RDD 和参数 RDD 执行联合操作的结果，生成一个新的 RDD，不去重。: 返回对输入 RDD 和参数 RDD 执行交集操作的结果，生成一个新
Docker启动rabbitmq最详细步骤
超级详细的docker启动rabbitmq镜像的步骤。看这一篇就足够了
kafka如何保证消息不被重复消费
（1）kafka有个offset的概念，当每个消息被写进去后，都有一个offset，代表他的序号，然后consumer消费该数据之后，隔一段时间，会把自己消费过的消息的offset提交一下，代表我已经消费过了。下次我要是重启，就会继续从上次消费到的offset来继续消费。但是当我们直接kill进程了
PySpark环境配置
首先，要知道PySpark是Spark为Python提供的API库，因此使用`pip install pyspark`下载pyspark不等于下载了spark。因此，配置pyspark环境，首先需要下载spark。（2）spark运行环境需要java，因此需要下载java。使用`pyspark`打开
Kafka消息队列中关于消息的实现原理
一个业务Topic中保存了100条消息数据，消费者1从Topic中消费消息数据，同时会定期将消费数据的偏移量写入到kafka内部的Consumer_offset主题上，如果消费者1在消费到第50条消息数据时，异常宕机不可用，此时消费者2启动后，就可以通过消费者1写入到Consumer_offset主
