centos配置Kafka-eagle（EFAK）无法登录
在配置Kafka-eagle时候，在web端能够打开登录界面，但是输入用户名和密码以后没反应。
Kafka数据同步
由于0.11版本之前Kafka的副本备份机依赖HW存数据不一致问题和丢失数据问题，因此在0.11版本引入了 Leader Epoch同步机制解决这个问题。其中Leader负责对应分区的读写、Follower负责同步分区的数据，0.11 版本之前Kafka使用highwatermarker（高水位）机
docker-compose部署 kafka 3.7 启用账号密码认证
docker-compose部署 kafka 3.7 并启用账号密码认证
Kafka、RabbitMQ、Pulsar、RocketMQ基本原理和选型
消息队列中间件是分布式系统中重要的组件，主要解决应用耦合，异步消息，削峰填谷等问题。实现高性能、高可用、可伸缩和最终一致性架构。 针对常见的消息队列进行探讨，并比较kafka、rabbitmq、rocketmq、pulsar这几种消息队列的异同，以及相关使用场景
Kafka性能优化策略综述：提升吞吐量与可靠性
优化 Kafka 的性能可以从多个方面入手，包括配置调优、架构设计和硬件资源优化。
Linux-Kafka 3.7.0 Kraft+SASL认证模式 集群安装与部署超详细
这个是3.2.0版本新引入的认证方式，可以参考 https://cwiki.apache.org/confluence/display/KAFKA/KIP-801%3A+Implement+an+Authorizer+that+stores+metadata+in+__cluster_metadat
Kafka第四篇——生产数据总体概括，源码解析分区策略，数据收集器，Sender发送线程，key值
流程图以及总体概述拦截器分区器以及分区计算策略为啥进行分区计算？producer生产者怎么知道有哪些分区？分区计算如何自定义实现分区器？想说的在图里啦！宝宝！💡如果key值忘记传递了呢！？数据校验数据收集器注意Sender发送线程
【实战】kafka3.X kraft模式集群搭建
相信很多同学都用过Kafka2.0吧，其中需要zookepper集群来做元数据管理和集群选举，大大增加了运维成本，而且也很是影响Kafka性能。言归正传今天我们就分享一期Kafka3.x Kraft模式集群搭建，简直不要太爽。
Kafka 之 ZooKeeper —— 稳定版本、弃用、操作
ZooKeeper 是一个分布式的协调服务，主要用于维护集群的元数据信息和配置信息。Kafka 集群依赖于 ZooKeeper 来存储和管理 Kafka 的元数据信息和配置信息。注：以上这些都低版本 Kafka 依赖 ZooKeeper 实现的，在高版本 Kafka 中，已经摆脱了对 ZooKeep
arm上的kafka测试
我们通常将Apache Kafka用在两类程序：1. 建立实时数据管道，以可靠地在系统或应用程序之间获取数据；2. 构建实时流应用程序，以转换或响应数据流。模型如下：Producers：可以有很多的应用程序，将消息数据放入到Kafka集群中。Consumers：可以有很多的应用程序，将消息数据从Ka
9 张图带你理解 Kafka 中高水位 ＨＷ
HW 是 Kafka 中 Offset 的一个值，HW 作为一个边界，Offset 小于 HW 的消息被称为已提交消息，这部分消息可以被消费者进行拉取消费，大于等于 HW 的消息被称为未提交消息，不能被消费者拉取。如下图：Offset 小于 108 的消息可以被消费者消费，Offset 大于等于 1
Kafka 技术总结
Kafka 是由 LinkedIn 创建并于 2011 年开源的一款分布式流处理平台，通过高吞吐量、低延迟、高可靠性和可扩展性特性，广泛应用于实时数据处理、数据集成与传输、日志和监控、消息队列等场景。创建主题：kafka-topics.sh --create --topic example-topi
Python操作Kafka基础教程
下载UI工具：https://kafkatool.com/download2/offsetexplorer_64bit.exe。外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传。点击是，然后就成功的使用客户端连接上Kafka了。下载好以后按照默认进行安装。安装Python3.8。
Flume与Kafka对接
Flume组件： agent source channel sinkkafka组件：节点集群服务器 **consumer **
zookeeper+kafka
zookeeper是一个开源的分布式的，为分布式框架提供协调服务的Apache项目Kafka 是一个分布式的基于发布/订阅模式的消息队列（MQ，Message Queue），主要应用于大数据实时处理领域。
Kafka 3.6.1 Kraft模式 集群安装
1）缓存/消峰有助于控制和优化数据流经过系统的速度，解决和生产消息和消费者消息的处理速度不一致的情况2）解耦允许你独立的扩展或修改两边的处理过程，只要确保它们遵守同样的接口约束3）异步通信允许用户把一个消息放入队列，但并不立即处理它，然后再需要的时候再去处理它们。
kafka底层原理性能优化详解：大案例解析(第29天)
Kafka的底层原理涉及多个方面，包括其架构设计、消息传递机制、数据存储结构以及集群管理等。本文是对Kafka底层原理和性能优化的详细解析，并结合实例进行说明。提示：以下是本篇文章正文内容，下面案例可供参考Kafka的底层原理涉及多个方面，包括其架构设计、消息传递机制、数据存储结构以及集群管理等。
Kafka案例2-kafka命令行的使用
(5)修改分区数（注意：分区数只能增加，不能减少）(3)创建名为firstkafka的topic。(6)再次查看firstkafka主题的详情。(4)查看firstkafka主题的详情。(2)查看当前服务器中所有的topic。(1)查看topic的命令参数。(7)删除topic。
Kafka集群部署
好了，Kafka的集群部署我们就讲到这里了，这几篇主要针对大数据集群环境的搭建进行了讲解，包括创建虚拟机、Linux操作系统的安装与配置、安装JDK、ZooKeeper集群部署、Hadoop集群部署、Spark集群部署、HBase集群部署以及Kafka集群部署。通过这几篇的学习，希望读者熟悉大数据集
Kafka系列之Kafka知识超强总结
Kafka 集群包含一个或多个服务器，服务器节点称为broker。broker存储topic的数据。如果某topic有N个partition，集群有N个broker，那么每个broker存储该topic的一个partition。如果某topic有N个partition，集群有(N+M)个broker
