通過前面的架構(gòu)簡述，知道了Producer是用來產(chǎn)生消息記錄，并將消息以異步的方式發(fā)送給指定的topic的某個partition的。另外還知道，它保證了消息的有序的發(fā)送。那么它是如何做到這些的呢？我們又該如何使用它的API來發(fā)送消息？

         Kafka Producer、Kafka Consumer相對于 Kafka Broker，都屬于客戶端。Kafka支持多種語言的客戶端。下面就根據(jù)Java 語言客戶端對Producer做個說明。

 

1、Producer API入門：

KafkaProducer是一個發(fā)送record到Kafka Cluster的客戶端API。這個類線程安全的。在應用程序中，通常的作法是：所有發(fā)往一個Kafka Cluster的線程使用同一個Producer對象.。如果你的程序要給多個Cluster發(fā)送消息，則需要使用多個Producer。