kafka消费组查看和删除
生产环境监控发现kafka存在大量消费组 查看消费组信息：./kafka-consumer-groups.sh --bootstrap-server ip:port --list查看特定消费组信息：./kafka-consumer-groups.sh --bootstrap-server ip:po
rabbitmq管理页面发送消息
rabbitmq
【Jeepay】02-Kafka实现延迟消息与广播模式详细设计
在专题的上一章中，重点讲解了项目的改造背景、难点分析。之所以会如此的追本溯源的去记录，第一是因为：一个可以落地的解决方案的敲定，是综合项目各方面的原因得到的。没有完美的架构，只有刚好的架构；没有满足一切的架构，只有满足目标的架构。第二是因为想要通过这样的记录，让后面的同学能快速的理解：实践中并不需要
zookeeper中节点信息的查看方式
zookeeper中节点信息的查看方式
kafka如何在运行中增加分区并重新分配副本
kafka如何在运行中增加分区并重新分配副本
安装rabbitmq图文详解步骤
安装rabbitmq图文详解步骤
分布式操作系统期末复习（辽宁大学王龙主讲）包含往年期末题
分布式操作系统期末复习（辽宁大学王龙主讲）
监控kafka topic，钉钉报警
没有使用一些重量级的组件，尽可能的快速的解决问题。
【Spring Cloud Alibaba Seata 处理分布式事务】——每天一点小知识
Seata 是由阿里巴巴开源的分布式事务解决方案。它提供了一个简单而强大的机制来管理和协调分布式事务。: TC 是事务协调器，负责协调并管理分布式事务的提交和回滚。: TM 是事务管理器，负责事务的开始、提交和回滚操作。: RM 是资源管理器，负责管理和协调参与分布式事务的各个资源。Spring C
kafka入门，生产者异步发送、回调函数，同步发送（四）
生产者异步发送、回调函数，同步发送
windows 上 Kafka 启动
1. 下载Kafka 官网下载链接本例 下载的是 kafka_2.12-3.1.0.tgz下载后解压2. 启动服务需遵循以下几步, 依次打开新的命令行启动, 也不要关闭之前的命令行窗口cmd 至 D:\tools\kafka_2.12-3.1.0启动 Zookeeper 服务, 默认端口 2181b
Kafka Connect JdbcSinkConnector的schema处理
1.使用Confluent Schema Registry 在写入kafka时，就用Avro、Protobuf 或 JSON Schema的converter进行schema的转换。kafka connect当写入到Mysql这类的关系型数据库时，使用JdbcSinkConnector，且kafka
Kafka：消费者手动提交
Kafka：设置消费者手动提交offset
Kafka有几种消费者分区分配策略？
这样可以明显减少系统资源的浪费，例如：之前consumer0、consumer1之前正在消费某几个分区，但由于rebalance发生，导致consumer0、consumer1需要重新消费之前正在处理的分区，导致不必要的系统开销。RoundRobinAssignor轮询策略是将消费组内所有消费者以及
RabbitMQ 能保证消息可靠性吗
前面我们在做MQ组件选型时，提到了rabbitMQ的消息可靠性，那么它到底可靠到什么程度？又是如何保证消息可靠性的呢？
java 集成kafka（支持单条消费和批量消费）
1、下载安装zk，kafka...（大把教程，不在这里过多阐述）8、测试类分别测试单条消费以及批量消费。7、消费者配置类（配置批量消费）5、生产者发消息的工具类。
Kafka：指定时间消费
Kafka：指定时间消费
虚拟机中docker安装rabbitmq 宿主机不能访问rabbitmq管理界面问题解决
解决不能访问RabbitMQ管理界面不能访问的问题
大数据技术原理与应用（第七章Zookeeper测试）
大数据技术原理与应用（第七章Zookeeper测试）
RabbitMq 手动ACK
rabbitmq ack操作
