KafkaProducer及其API

KafkaProducer 向Kafka集羣發佈記錄的Kafka客戶端。 生產者是線程安全的，並且在線程之間共享一個生產者實例通常比擁有多個實例要快。 生產者由緩衝空間池組成，緩衝空間池保存尚未傳輸到服務器的記錄，以及後臺I/O線程，該線程負責將這些記錄轉換爲請求並將它們傳輸到集羣。未在使用後關閉生產者將泄漏這些資源。 send()方法是異步的。調用時，它將記錄添加到掛起記錄發送的緩衝區，並立即返

>>阅读原文<<