Kafka 实战 - SpringBoot 中使用@KafkaListener详解与使用
在Spring Boot项目中使用注解，可以方便地监听和处理从Kafka主题中流入的消息。
「Kafka」Kafka单机和集群安装（二）
集群启动命令后，会打开多个黑窗口，每一个窗口都是一个kafka服务，请不要关闭，一旦关闭，对应的kafka服务就停止了。如果启动过程报错，主要是因为zookeeper和kafka的同步问题，请先执行cluster-clear.cmd文件，再执行cluster.cmd文件即可。因为Kafka启动前，必
Kafka基础架构详解
Kafka基础架构
docker安装flink
安装flink + kafka
Kafka学习-Java使用Kafka
Kafka是Apache旗下的一款分布式流媒体平台，Kafka是一种高吞吐量、持久性、分布式的发布订阅的消息队列系统。它被广泛应用于实时数据流处理、日志收集和处理以及消息队列等场景。本文将深入介绍Kafka的概念、原理、作用和应用场景。
Kafka效率篇-提升效率三板斧
总结一下本文的大致内容，主要解释了kafka如何提高效率的，主要解决了小型IO和大量的字节拷贝问题。小型IO的问题，kafka的解法是转微批的方式。字节拷贝问题，kafka利用了零拷贝技术实现，减少了数据的重复拷贝问题，但目前还没做到真正的“零拷贝”。利用压缩技术，使的网络带宽能够更高效的使用。后续
Kafka 消费端消费重试和死信队列
前些天发现了一个巨牛的人工智能学习网站，通俗易懂，风趣幽默，忍不住分享一下给大家。点击跳转到网站，这篇文章男女通用，看懂了就去分享给你的码吧。Spring-Kafka 提供消费重试的机制。当消息消费失败的时候，Spring-Kafka 会通过消费重试机制，重新投递该消息给 Consumer ，让 C
kafka源码学习（二）服务端源码
本篇主要说明了源码学习过程中服务端的相关知识点。通过本章节的学习，1、对服务端的网络、存储、副本同步、集群管理相关的细节又回顾了一篇，比之前死记硬背好很多。2、感觉很多架构的设计还是来源于实际需求，当然kafka的核心点就是：异步、削峰、解耦。注意：1、Kafka网络设计，理解超高并发的网络设计2、
一篇文章告诉你CentOS7中从0到1搭建kafka消息中间件
在 CentOS 7 上安装 Apache Kafka 需要一些准备步骤，主要包括安装必要的依赖、下载 Kafka 以及配置 Zookeeper 和 Kafka 服务。
深入探索：Zookeeper+消息队列（kafka）集群
本文主要介绍zookeeper集群+kafka集群的部署，希望对你有帮助！
深入解析Kafka中的Lag现象
本文将带您深入研究Apache Kafka中的Lag现象，揭示在分布式系统中消息延迟背后的奥秘。了解Lag的机制对于确保消息的实时性、优化系统性能以及监控分布式系统的稳定性至关重要。我们将深入探讨Lag的定义、影响因素、监控与调优策略，为您呈现Lag的全貌。
Kafka 2.13-3.7.0 在 Windows 上的安装与配置指南
Kafka 2.13-3.7.0 在 Windows 上的安装与配置指南
Helm安装kafka3.7.0无持久化（KRaft 模式集群）
如果使用指定的zookeeper，kraft模式要关闭，修改kraft.enable 的值为false，新版kafka新增了一个kraft模式，他与zookeeper是冲突的，不能同时使用。2.在k8s-master01节点上开启两个窗口，一个用于生产者，一个用作消费者。关于kafka集群扩容，这里
如何在生产环境中以非 Root 用户启动 Kafka
在生产环境中以非 root 用户启动 Kafka 是一个最佳实践，能够有效提高系统安全性。创建并配置 Kafka 用户。设置目录权限确保 Kafka 用户可以访问必要的文件和目录。修改 systemd 服务文件，使 Kafka 服务以 Kafka 用户启动。启动和验证 Kafka 服务，确保配置正确
Kafka安全认证机制详解之SASL_PLAIN_kafka sasl认证，7年老网络安全一次操蛋的面试经历
在结束之际，我想重申的是，学习并非如攀登险峻高峰，而是如滴水穿石般的持久累积。尤其当我们步入工作岗位之后，持之以恒的学习变得愈发不易，如同在茫茫大海中独自划舟，稍有松懈便可能被巨浪吞噬。然而，对于我们程序员而言，学习是生存之本，是我们在激烈市场竞争中立于不败之地的关键。一旦停止学习，我们便如同逆水行
kafka的简单使用
kafka的简单使用
Kafka-Java客户端数据生产流程解析，从发送类型实现代码到序列化器实现代码！
**自定义序列化器*/@Override@Overridetry {= null) {} else {= null) {} else {@Override使用自定义的序列化器Company company = Company.builder().name(“kafka”) .address(“北京”
修复 Apache Kafka 中的远程代码执行漏洞CVE-2023-25194
在 Kafka Connect 中发现可能的 RCE 和拒绝服务问题。更新 阿帕奇软件基金会 (ASF) 已解决了一个漏洞，该漏洞可被利用来使用 Kafka Connect 发起远程代码执行 (RCE) 攻击。该关键漏洞于 2 月 8 日公布，被追踪为 CVE-2023-25194。Apache K
Kafka 面试八股题整理
本文是博主自行收集的Kafka相关的八股文问题，博主还在准备暑期实习中，应该会持续更新....
从面试角度一文学完 Kafka
Kafka Consumer 的常见配置？Consumer 什么时候会被踢出集群？当有 Consumer 加入或退出时，Kafka 会作何反应？什么是 Rebalance，何时会发生 Rebalance？
