Kafka Producer

Kafka Producer在发送消息大致有以下流程： 首先将消息封装在ProducerRecord中，并且序列化 将序列化后的消息发送给partitioner，partitioner主要用来确定消息发往哪个分区，默认的分区策略是轮询，如果消息有key，具有相同key的消息可以被发往同一分区，Kafka Producer也允许用户直接指定要发往的分区 Producer有一个专门的Sender线程会

>>阅读原文<<