kafka

一、Kafka 概述 1.1 为什么需要消息队列（MQ） 主要原因是由于在高并发环境下，同步请求来不及处理，请求往往会发生阻塞。比如大量的请求并发访问数据库，导致行锁表锁，最后请求…

Apache kafka 是一个分布式的基于push-subscribe的消息系统，它具备快速、可扩展、可持久化的特点。它现在是Apache旗下的一个开源系统，作为hadoop生态…

最近在做微服务的迁移改造工作，其中有一个服务需要订阅多个Kafka，如果使用spring kafka自动配置的话只能配置一个Kafka，不符合需求，该文总结了如何配置多个Kafka…

👏作者简介：大家好，我是爱吃芝士的土豆倪，24届校招生Java选手，很高兴认识大家 📕系列专栏：Spring源码、JUC源码、Kafka原理 &#x…

目录 Kafka 概述 为什么需要消息队列（MQ） 使用消息队列的好处 消息队列的两种模式 Kafka 定义 Kafka 简介 Kafka 的特性 Kafka 系统架构 在zook…

一、ZooKeeper 的核心功能 ZooKeeper 是一个广泛使用的开源分布式协调服务框架，它在确保数据一致性方面表现出色，同时也可以作为一个轻量级的分布式存储系统。它特别适合…

目录 什么是Zookeeper？ Zookeeper 工作机制 Zookeeper 特点 Zookeeper 数据结构 Zookeeper 选举机制 实验 部署 Zookeeper…

创建kafka我们需要分两步走： 前沿：请大家注意在云服务器上部署任何新的服务一定要注意在对应云安全配置上开放此端口号   1、使用docker 先拉取 zookeeper，因为k…

开头还是介绍一下群，如果感兴趣PolarDB ,MongoDB ,MySQL ,PostgreSQL ,Redis, Oceanbase, Sql Server等有问题，有需求都可…

Kafka 数据存储 1.文件目录2.日志分段3.日志索引3.1 偏移量索引3.2 时间戳索引4.日志清理4.1 日志删除4.1.1 基于时间4.1.2 基于日志大小4.1.3 基…

消息队列 生产者产生消息，将消息放到MQ中，消费者从MQ中获取消息进行消费 消息队列的作用 异步处理 将一些耗时的操作请求传输给MQ，直接给用户返回成功的结果。其他系统可以消费MQ…