Kafka Producer

Kafka Producer在發送消息大致有以下流程： 首先將消息封裝在ProducerRecord中，並且序列化 將序列化後的消息發送給partitioner，partitioner主要用來確定消息發往哪個分區，默認的分區策略是輪詢，如果消息有key，具有相同key的消息可以被髮往同一分區，Kafka Producer也允許用戶直接指定要發往的分區 Producer有一個專門的Sender線程會

>>阅读原文<<