# 前述
在本章节中,您将学习如何在 Kafka 集群中的节点之间迁移主题分区。向现有集群添加节点时,Kafka 不会自动将任何分区迁移到新节点,而您需要手动迁移分区。这对于节点故障也有效,因为现有分区不会自动移动到剩余节点。
```ad-info
title: 简单理解
Broker 3 节点挂了,Broker 3 节点上的分区(Par...
# 前述
在本章节中,我们将实践 Kafka 的基本操作。首先,会创建一个新的主题(Topic)并执行消息的生产与消费。随后,将模拟一次节点故障,通过主动关闭集群中的一个 Broker,来检验 Kafka 集群的容错能力和服务的连续性。
# 主题管理
## 创建主题
创建主题(Topic)`one-topic`,并设置副本数为 `2`,检测主...
Kafka 客户端管理工具有多种选择,主要包括:
1. [provectus/kafka-ui](https://github.com/provectus/kafka-ui):此项目已停止更新。
2. [kafbat/kafka-ui](https://github.com/kafbat/kafka-ui):作为前者的替代方案,称为 Kafbat...
本文主要介绍了 Kafka 集群的规划与部署过程,特别是在 KRaft 模式下的设置。文章首先阐明了 KRaft 模式中如何替代 Zookeeper,使用 Controller 节点来管理集群。接着,详细描述了在所有 Kafka 节点上安装 Java 的步骤、Kafka 部署的基础设置、修改主机的 hosts 文件、创建部署目录、下载和解压 Kafka 二进制包,以及防火墙配置,以确保正常通信。
随后,文章列出了关键的 Kafka 配置参数和每个 Kafka 节点的具体设置,包括服务的启动和状态检查。此外,还详细说明了如何通过 systemd 管理 Kafka 服务,启用 JMX 监控并进行集群可用性测试,确保在节点失效时系统能够正常转移 Leader 权限。最后,提供了相关文档的参考链接,助于读者深入了解 Kafka 设置和管理的最佳实践。
# kafka 介绍
## 什么是 Kafka
Kafka 是由 `LinkedIn` 公司开发并开源的一款**分布式流处理平台**(Distributed Streaming Platform)。它最初被设计为一个高吞吐量的分布式消息队列,但现在已经发展成为一个功能强大的、支持多分区、多副本的、基于发布/订阅模式的流处理平台。
## Kaf...
Kafka 过去一直使用 Zookeeper 来管理元数据、领导者(Leaders)选举和集群协调。然而,在 KRaft(Kafka Raft)模式下,Kafka 摆脱了对 Zookeeper 的依赖,并使用 Raft 共识算法引入了自管理元数据仲裁机制。
KRaft 模式提供了更快的元数据传播速度、更强的一致性以及更可扩展的架构。下面,我们结...