Flume-Kafka-Sink逐批生成消息,并在写入失败后重试。在一些经纪人失败期间,一些分区领导无法到达。当批量写入发生时,一些分区将成功,但有些失败,当Flume-Kafka-Sink重试时,成功部分将重复。