windows环境下安装zookeeper
解压后将prunmgr.exe(监控服务配置及运行的程序)和prunsrv.exe(做服务的执行程序)两个可执行文件复制到zookeeper的bin目录下。在bin目录下双击zkCli.cmd，打开客户端(此时的服务端zkServer的dos窗口不要关闭)，出现“欢迎”字样，说明安装成功。复制zoo
springcloud：新一代分布式定时任务框架——PowerJob
PowerJob是基于java开发的企业级的分布式任务调度平台，与xxl-job一样，基于web页面实现任务调度配置与记录，使用简单，上手快速，因此迅速得到用户的欢迎。相对于其他定时任务框架具有无锁化设计，更强悍的性能支撑，我们通过官网的产品对比可以了解详情。定时任务类型与传统的定时任务框架对比，p
kafka常用命令
【代码】kafka常用命令。
你在项目中是如何使用kafka的？
较少的分区数可能会限制并行性能，而较多的分区数可能会增加系统管理的复杂性。较少的分区数可能会导致消息处理能力不足，而较多的分区数则会增加系统的管理复杂性。通过合理设置分区数、优化生产者端性能和进行消费者组管理，可以充分发挥Kafka的优势，并构建可靠的消息传递系统。另一方面，如果订单数据的有序性对业
Zookeeper的应用场景
我们使用getChildren方法来获取队列中的第一个消息，并使用getData方法来获取消息的内容。在每个循环迭代中，我们使用dequeue方法来获取队列中的第一个消息，并打印出消息的内容。当队列为空时，我们跳出循环并结束程序。分布式队列通常采用先进先出（FIFO）的方式实现，即每个消息都会被依次
Kafka入门到精通
buffer.memory它代表缓冲区内存的大小，默认为32M，batch.size代表消息批次的大小，默认为16kb，在BufferPool中，batch.size其实就是代表一个ByteBuffer的大小，因为BufferPool只管理batch.size大小的ByteBuffer，在kafka
3.精通RabbitMQ—消息队列、RabbitMQ
RabbitMQ整体上是一个生产者与消费者模型，主要负责接收、存储和转发消息。支持多种消息传递模式，如点对点发布/订阅等。消息中间件是一种解决应用程序之间通信问题的技术，它将应用程序解耦，并提供了可靠性、灵活性和可扩展性等优点。
【Kafka】Kafka consumer lag 为负数
最近对Kafka 集群部署了监控，并集成了granfana图标展示。发现有时候为负数。于是进行一番查询，并总结整理下。
Kafka消息监控管理工具Offset Explorer的使用教程
Offset Explorer是一款用于监控和管理Apache Kafka集群中消费者组偏移量的开源工具。它提供了一个简单直观的用户界面，用于查看和管理Kafka消费者组偏移量的详细信息。
中间件上云部署 zookeeper
kubectl drain 操作时遵循PDB对象的设定，如果在该节点上运行了属于统一服务的多个pod，则为了保证最少存活数量，系统会确保每终止一个pod就会在健康的node上启动新的pod后，再继续终止下一个pod容器。1、 MinAvailable参数：表示最小可用POD数，表示应用POD集群处
rabbitmq开启后台管理页面、创建用户及授权
rabbitmq开启后台管理页面、创建用户及授权
谈谈 Kafka 的幂等性 Producer
使用消息队列，我们肯定希望不丢消息，也就是消息队列组件，需要保证消息的可靠交付。消息交付的可靠性保障，有以下三种承诺：最多一次、至少一次和精确一次。
RabbitMQ - 简单案例
RabbitMQ - 简单案例
RabbitMQ实现延迟队列
RabbitMQ 延迟队列是指将消息先放入队列中，但是并不立即消费该消息，而是在一定时间后再进行消费的队列。延迟队列可以用来解决某些需要经过一段时间才能处理的任务，例如超时未支付订单的关闭、定时发送消息等场景。
kafka基本概念及操作
kafka基本概念及操作
RabbitMQ
原因在于RabbitMQ服务端代码是使用并发式语言erlang编写的，双击.exe文件进行安装，安装完成之后创建一个名为ERLANG_HOME的环境变量，其值指向erlang的安装目录，同时将%ERLANG_HOME%\bin加入到Path中，最后打开命令行，输入erl，如果出现erlang的版本信
Kafka入门,保姆级教学
producer：发布消息的对象称之为主题生产者（Kafka topic producer）topic：Kafka将消息分门别类，每一类的消息称之为一个主题（Topic）consumer：订阅消息并处理发布的消息的对象称之为主题消费者（consumers）broker：已发布的消息保存在一组服务器中
分布式 - 消息队列Kafka：Kafka消费者和消费者组
在Kafka中，一个消费者组中的每个消费者会消费主题下不同分区的消息，而不同消费者组中的消费者则可以同时消费相同分区的数据。在这些情况下，单个消费者无法跟上数据生成的速度，因此可以增加更多的消费者来分担负载，让每个消费者只处理部分分区的消息，这是横向扩展消费者的主要方式。消费者组是一个逻辑上的概念，
2023-07-10：Kafka如何做到消息不丢失？
当Follower副本与Leader副本之间出现落后时，Kafka会将Follower副本从ISR（In-Sync Replicas）中移除。只有当Follower副本与Leader副本之间的差距不大时，才会将Follower副本重新加入ISR，以确保消息不丢失。如果Follower副本成功复制了消
kafka权限控制功能
Kafka Topic 权限控制可以通过使用 Apache Kafka 的内置安全特性来实现。这主要涉及到两个方面：认证（Authentication）和授权（Authorization）。
