kafka-broker

Kafka Broker 启动与运维

补充说明

kafka-broker 是 Kafka 服务端进程，负责分区存储、副本复制和客户端请求。Kafka 4.0 起只支持 KRaft 模式，ZooKeeper 元数据模式已被移除；3.x 及更早版本仍可用 ZooKeeper。

常用示例

kafka-server-start.sh config/server.properties
kafka-server-stop.sh
kafka-topics --bootstrap-server broker:9092 --describe
kafka-configs --bootstrap-server broker:9092 --entity-type brokers --entity-name 1 --describe
kafka-log-dirs --bootstrap-server broker:9092 --describe
kafka-reassign-partitions --bootstrap-server broker:9092 --reassignment-json-file plan.json --execute
kafka-leader-election --bootstrap-server broker:9092 --election-type preferred --all-topic-partitions
kafka-dump-log --files /data/kafka/app-0/00000000000000000000.log --print-data-log

KRaft 初始化：

kafka-storage.sh random-uuid
kafka-storage.sh format -t <uuid> -c config/kraft/server.properties

易错点与排错

• listeners 和 advertised.listeners 不一致时，客户端能连上却拿不到数据。
• broker.id 必须唯一；KRaft 模式下节点 ID 和 controller 配置要匹配。
• log.dirs 磁盘满会导致写入失败和副本离线；监控要覆盖所有数据盘。
• 副本因子不能超过 broker 数；min.insync.replicas 影响写入可用性。
• unclean.leader.election.enable=true 可能丢数据，生产慎用。
• 分区重分配会产生大量 I/O；避开高峰并确认副本同步完成。
• JMX 指标和日志是排查 broker 问题的主要入口；不要只看客户端报错。

相关命令

• kafka-topics — 主题管理
• kcat — 生产消费调试
• zookeeper — 旧架构元数据

读完自测

合上页面，先回答，再展开对照。

1. 客户端能连上 broker 却拿不到数据，先查哪个配置？
2. unclean.leader.election.enable=true 有什么风险？
3. 执行分区重分配前要注意什么？