错误：

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,