当前位置:   article > 正文

Kafka:exception is org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not

notleaderforpartitionexception: this server is not the leader for that topic

错误:

Failed to send; nested exception is org.apache.kafka.common.errors.NotLeaderForPartitionException: This server is not the leader for that topic-partition.

找不到推送消息服务器的所在分区副本leader,那估计就是分区所在所有的副本服务都挂了,kafa挂掉了

1.kafka的几个概念:

producer:生产者。
consumer:消费者。
topic: 消息以topic为类别记录,每一类的消息称之为一个主题(Topic)。为了提高吞吐量,每个消息主题又会有多个分区
broker:以集群的方式运行,可以由一个或多个服务组成,每个服务叫做一个broker;消费者可以订阅一个或多个主题(topic),并从Broker拉数据,从而消费这些已发布的消息。

每个消息(也叫作record记录,也被称为消息)是由一个key,一个value和时间戳构成。

一个broker 相当于一个kafka 服务实例,一个服务实例里面有多个topic 主题,

一个主题下面有多个分区partition,

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/不正经/article/detail/142358
推荐阅读
相关标签
  

闽ICP备14008679号