你能解释一下Kafka-topics.sh-Describe正在播放什么吗？我正在看一段教程视频，也在阅读Apache文档，但我需要更多地澄清一下我在这张图中看到的以下专栏的内容。
Leader：这是指向第三个代理还是指向第三个分区[2]？
副本：这是否指向代理：分区？
ISR：这是否指向代理：分区？
如果有人能解释一下A、B、C、D栏是什么，我将不胜感激。
wvmv3b1j1#
主题名称：“INSTALL_TEST2”
4个分区(Partition 0、Partition 1、Partition 2、Partition 3)，您对该主题的复制系数为2，即您的主题中的数据将被存储(复制)在2个Broker中，以实现冗余。在Kafka中，每个分区都有一个领导者，来自生产者和消费者的所有请求都被发送给领导者。
**Leader列(您的图片中的B列)**显示每个分区的Leader的经纪人ID。(Kafka在Broker之间平均分配分区领导权，以实现负载均衡)
**Replicas列(您的镜像中的C列)**展示了为每个分区复制数据的Broker的ID。第一个id表示首选领导。这意味着Kafka将试图让这位经纪人成为分区的领导者。
**ISR(镜像中的D列)**表示同步复制。在Kafka中，当消息被发送到主题分区时(首先消息被接收并存储在Leader中)，如果您的复制因子大于1，则副本代理发送FETCH请求，该数据被复制到其他代理。如果跟随者(副本)代理与领先者相差不远，则它是同步的(如下所述)。如果分区引导者出现故障，Kafka会选择ISR作为故障转移的新引导者。
来自Kafka文档：配置参数plica.lag.time.Max.ms现在不仅指自上次从副本获取请求以来经过的时间，还指自副本上次捕获以来经过的时间。仍在从领导者那里获取消息，但没有跟上Replica.lag.time.Max.ms中的最新消息的副本将被视为不同步。
1条答案
按热度按时间wvmv3b1j1#
主题名称：“INSTALL_TEST2”
4个分区(Partition 0、Partition 1、Partition 2、Partition 3)，您对该主题的复制系数为2，即您的主题中的数据将被存储(复制)在2个Broker中，以实现冗余。在Kafka中，每个分区都有一个领导者，来自生产者和消费者的所有请求都被发送给领导者。
**Leader列(您的图片中的B列)**显示每个分区的Leader的经纪人ID。(Kafka在Broker之间平均分配分区领导权，以实现负载均衡)
**Replicas列(您的镜像中的C列)**展示了为每个分区复制数据的Broker的ID。第一个id表示首选领导。这意味着Kafka将试图让这位经纪人成为分区的领导者。
**ISR(镜像中的D列)**表示同步复制。在Kafka中，当消息被发送到主题分区时(首先消息被接收并存储在Leader中)，如果您的复制因子大于1，则副本代理发送FETCH请求，该数据被复制到其他代理。如果跟随者(副本)代理与领先者相差不远，则它是同步的(如下所述)。如果分区引导者出现故障，Kafka会选择ISR作为故障转移的新引导者。
来自Kafka文档：
配置参数plica.lag.time.Max.ms现在不仅指自上次从副本获取请求以来经过的时间，还指自副本上次捕获以来经过的时间。仍在从领导者那里获取消息，但没有跟上Replica.lag.time.Max.ms中的最新消息的副本将被视为不同步。