Kafka的三種客戶端線程模型和一個小驚喜

Kafka 作爲一個流式數據平臺，對開發者提供了三種客戶端：生產者 / 消費者、連接器、流處理。本文着重分析這三種客戶端的線程模型。看到最後的通常都有驚喜。 消費者的線程模型 0.8 版本以前的消費者客戶端會創建一個基於 ZK 的消費者連接器，一個消費者客戶端是一個 Java 進程，消費者可以訂閱多個主題，每個主題也可以多個線程。爲了讓消息在多個節點被分佈式地消費，提高消息處理的吞吐量，Kafka

>>阅读原文<<