Kafka 使用 Zookeeper 来管理主题的首选副本。当一个主题被创建时,Zookeeper 会分配一个首选副本节点给该主题。为了确认主题的首选副本已经正确配置,可以通过以下步骤来检查:

  1. 使用 Kafka 提供的命令行工具查看主题的分区分配情况。命令为:

    kafka-topics.sh --describe --zookeeper <Zookeeper地址> --topic <主题名称>
    
  2. 检查每个分区的首选副本是否与预期相同。首选副本的编号可以在上一步中的输出中找到。

    Topic: <主题名称>	PartitionCount: <分区数量>	ReplicationFactor: <副本数量>	Configs:
    	   Topic: <主题名称>	Partition: 0	Leader: <首选副本编号>	Replicas: <副本编号列表>	Isr: <同步副本编号列表>
    	   Topic: <主题名称>	Partition: 1	Leader: <首选副本编号>	Replicas: <副本编号列表>	Isr: <同步副本编号列表>
    	   ...
    

如果每个分区的首选副本与预期相同,则说明主题已经正确配置了首选副本。否则,需要重新配置主题的首选副本。

如何确认 Kafka 主题的首选副本配置正确

原文地址: https://www.cveoy.top/t/topic/lyER 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录