Kafka筆記整理（二）：Kafka Java API使用

[TOC]

下面的測試代碼使用的都是下面的topic：

關于producer API的使用說明，可以檢視<code>org.apache.kafka.clients.producer.KafkaProducer</code>這個類的代碼注釋，有非常詳細的說明，下面就直接給出程式代碼及測試。

其實這個配置檔案就是kafka conf目錄下的配置檔案，隻是這裡要做相應的修改，關于每個字段的含義，可以檢視<code>org.apache.kafka.clients.producer.KafkaProducer</code>這個類的代碼注釋。

在終端中啟動消費者監聽topic的消息：

然後執行生産者程式，再檢視終端輸出：

先執行消費者的代碼，然後再執行生産者的代碼，在消費者終端可以看到如下輸出：

可以通過自定義partitioner來決定我們的消息應該存到哪個partition上，隻需要在我們的代碼上實作Partitioner接口即可。

繼續使用前面的消費者的代碼，同時需要在producer.properties中指定我們定義的partitioner，如下：

先執行消費者代碼，然後再執行生産者代碼，檢視終端輸出。

生産者終端輸出（主要是自定義partitioner中的輸出）：

消費者終端輸出：