Apache Kafka - 流式处理
Kafka被广泛认为是一种强大的消息总线，可以可靠地传递事件流，是流式处理系统的理想数据来源。流式处理系统通常是指一种处理实时数据流的计算系统，能够对数据进行实时的处理和分析，并根据需要进行相应的响应和操作。与传统的批处理系统不同，流式处理系统能够在数据到达时立即进行处理，这使得它们特别适合需要实时
【kafka面试题2】如何保证kafka消息的顺序性
【kafka面试题2】如何保证kafka消息的顺序性
Kafka的下载安装以及使用
kafka安装与使用
关于kafka压力测试（使用官方自带脚本测试）
如何测试kafka集群的性能
【Kafka】第一章
Kafka传 统定义：Kafka是一个分布式的基于发布/订阅模式的消息队列（Message Queue），主要应用于大数据实时处理领域。======>什么是分布式简单来说，分布式就是将一个大问题拆分成多个小问题，逐一解决，最终协同合作，而将多个系统协同合作完成一个特定任务，支持分布式处理的软件系统，
MQ - 闲聊MQ一二事儿 （Kafka、RocketMQ 、Pulsar ）
ookeeper 是 cp 强一致架构的一种，其内部使用 zab 算法，进行信息同步和容灾，在信息量较小的情况下，性能较好，当信息交互变多，因为同步带来的性能损耗加大，性能和吞吐量降低。kafka 的整体性能收到了 topic 数量的限制，这和底层的存储有密不可分的关系，我们上面讲过，当消息来的时候
基于 kRaft 搭建单机 kafka 测试环境
使用 docker-compose 在单机搭建有三个节点的 kafka 集群。
【docker】docker安装带ui界面的kafka
使用docker-compose 一键安装kafka和kafka-ui界面
kafka复习：（17）seekToBeginning的用法
从分区的开始进行消费，因为kafka会定期清理历史数据，所以分区开始的位移不一定为0。seekToBeginning只是从目前保留的数据中最小的offset进行消费。
Kafka 集群搭建过程
跟着尚硅谷海哥文档搭建的Kafka集群环境，在此记录一下，侵删注意：博主在服务器上搭建环境的时候使用的是一个服务器，所以这篇博客可能会出现一些xsync分发到其他服务器时候的错误，如果你在搭建的过程中出现了错误，欢迎评论来访，我们一起解决。尚硅谷大数据Hadoop教程，hadoop3.x搭建到集群调
kafka系列：windows安装kafka
kafka系列：windows安装kafka
windows/linux 安装zookeeper + Kafka (含自启动)运行教学
详细的一站式实战，让笔者带你快速使用上手使用kafka~~~
Linux安装Kafka及其环境配置
在Kafka集群（Cluster）中，一个Kafka节点就是一个Broker，消息由Topic来承载，可以存储在1个或多个Partition中。发布消息的应用为Producer、消费消息的应用为Consumer，多个Consumer可以促成Consumer Group共同消费一个Topic中的消息：
Python消费Kafka与优化
python使用kafka-python库消费kafka，消费能力一直上不去，原来是这样解决的...
SpringBoot3集成Kafka
Kafka是一个开源的分布式事件流平台，常被用于高性能数据管道、流分析、数据集成和关键任务应用，基于Zookeeper协调的处理平台，也是一种消息系统，具有更好的吞吐量、内置分区、复制和容错。
Spring Boot 整合 kafka
启动方式参考上一篇文章，
吊炸天的 Kafka 图形化工具 Eagle，必须推荐给你
Kafka是当下非常流行的消息中间件，据官网透露，已有成千上万的公司在使用它。最近实践了一波Kafka，确实很好很强大。今天我们来从三个方面学习下Kafka：Kafaka在Linux下的安装，Kafka的可视化工具，Kafka和SpringBoot结合使用。希望大家看完后能快速入门Kafka，掌握这
JAVA连接Kafka及SSL认证
【代码】JAVA连接Kafka及SSL认证。
Kafka及Kafka消费者的消费问题及线程问题
kafka消费与线程池遇到的问题分析
Kafka经典三大问：数据有序丢失重复
的情况下，是有可能存在消息丢失的情况的，因为producer收到leader写入成功的通知就认为推送成功，但实际上leader副本在把消息同步到follower副本的时候失败了，这时候消息就丢失了。例如消费者已经获取到这个数据，并且提交了offset，但后续在对数据进行业务操作的时候挂掉了，导致数据
