赞
踩
错误:
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,
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。