kafka 积压消息查询
在目录下，执行下面的脚本，查询kafka积压消息。
kafka如何保证消息的有序性
软件测试常见面试题：kafka如何保证消息的有序性
ELK-日志服务【kafka-配置使用】
kafka-0110.0.0.21kafka-0210.0.0.22kafka-0310.0.0.23【2】安装kafka集群
Kafka查看消息是否堆积（服务器）
kafka消息偏移量查看
Kafka3.0.0版本——消费者（消费者组详细消费流程图解及消费者重要参数）
Kafka3.0.0版本——消费者（消费者组详细消费流程图解及消费者重要参数）
DDS与MQ对比分析
努力了那么多年,回头一望,几乎全是漫长的挫折和煎熬。对于大多数人的一生来说,顺风顺水只是偶尔,挫折、不堪、焦虑和迷茫才是主旋律。我们登上并非我们所选择的舞台,演出并非我们所选择的剧本。继续加油吧！
kafka--kafka基础概念-ISR详解
因为P1S1同步数据 可能花费 50ms P1S2可能花费60ms。当绿色P1接收到写入的数据，要同步到紫色的P1S1和P1S2。使用In Sync Replicas 也就是ISR概念。同步时间是可以设置规定时间的（容忍时间）绿色部分主要监督 紫色部分有没有超时。主要是讲 主 往 从同步中的问题。
Spring boot使用Kafka Java反序列化漏洞 CVE-2023-34040
背景：公司项目扫描到 Spring-Kafka上使用通配符模式匹配进行的安全绕过漏洞 CVE-2023-20873Spring Kafka 是 Spring 框架提供的一个库，它提供了使用 Apache Kafka 的便捷方式。Apache Kafka 是一个开源的流处理平台，主要用于构建实时数据流
分布式应用之Zookeeper和Kafka
【代码】分布式应用之Zookeeper和Kafka。
使用finksql方式将mysql数据同步到kafka中，每次只能同步一张表
使用finksql方式将mysql数据同步到kafka中，每次只能同步一张表
FlinkCDC的介绍和原理
总的来说，FlinkCDC 的原理就是通过解析 MySQL 中的 binlog，抓取到最新的增量数据，并将其转换为 Flink 支持的数据格式，然后将增量数据同步到 Flink 或者其他的计算引擎中进行处理。FlinkCDC 是阿里巴巴开源的一个基于 Flink 的分布式流式数据同步工具，它可以将
Spring Boot集成Kafka详解
Spring Boot是一个用于构建独立的、生产级的Java应用程序的框架，而Kafka是一种高吞吐量的分布式发布订阅消息系统。在本文中，我们将详细解释如何在Spring Boot项目中集成Kafka。
【Flink写出到kafka报错ClassNotFoundException】
flink写出到Kafka、jar包冲突排查
kafka 理论知识
Kafka是一个分布式的消息订阅系统。
Zookeeper+kafka
Zookeeper是一个开源的分布式的，为分布式框架提供协调服务的Apache项目。主要原因是由于在高并发环境下，同步请求来不及处理，请求往往会发生阻塞。比如大量的请求并发访问数据库，导致行锁表锁，最后请求线程会堆积过多，从而触发 too many connection 错误，引发雪崩效应。我们使用
Go操作各大消息队列教程（RabbitMQ、Kafka）
Go操作各大消息队列教程（RabbitMQ、Kafka）
基于 SpringBoot3 仿牛客论坛项目代码及踩坑总结
一个基本功能完整的论坛项目。项目主要功能有：基于邮件激活的注册方式，基于 MD5 加密与加盐的密码存储方式，登陆功能加入了随机验证码的验证。实现登陆状态的检查、为游客和已登录用户展示不同界面与功能。实现不同用户的权限控制和网站数据统计(UV、DAU)，管理员可以查看网站数据统计和网站监控信息。支持用
Kafka（Windows）安装配置启动（常见错误扫雷）教程
下载到本地后，将文件解压到 D:\kafka_2.11-2.4.0，该文件夹包括了所有相关的运行文件及配置文件，其子文件夹bin\windows 下放的是在Windows系统启动zookeeper和kafka的可执行文件，子文件夹config下放的是zookeeper和kafka的配置文件。注意下载
【Kafka原理】分区的leader和follower
Kafka启动时，会在所有的broker（集群节点）中选择一个controller之前的leader和follower是针对分区而言的，而controller是针对broker的创建topic、添加分区、修改副本数量等管理任务都是由controller完成的Kafka分区leader的选举，也是有c
kafka @KafkaListener 动态接收topic
这里用到了获取配置文件的信息因为@value跟@Bean在同一个文件里会先执行@value。但是某些业务场景 kafka定义的topic会不同这时候就需要传入变量才可以实现。@KafkaListener 里边的 topics 必须是常量，不可以是变量。这里是获取topic 其实可以在对应的@Bean
