kclient提供了三種使用方法，對於每一種方法，按照下面的步驟可快速構建Kafka生產者和消費者程序。
前置步驟
1) 下載源代碼后在項目根目錄執行如下命令安裝打包文件到你的Maven本地庫。
mvn install
2) 在你的項目pom.xml文件中添加對kclient的依賴。
<dependency>
<groupId>com.robert.kafka</groupId>
<artifactId>kclient-core</artifactId>
<version>0.0.1</version>
</dependency>
3) 根據Kafka官方文檔搭建Kafka環境，並創建兩個Topic， test1和test2。
4) 然后，從Kafka安裝目錄的config目錄下拷貝kafka-consumer.properties和kafka-producer.properties到你的項目類路徑下，通常是src/main/resources目錄。
Java API
Java API提供了最直接，最簡單的使用kclient的方法。
構建Producer示例：
構建Consumer示例：
Spring環境集成
kclient可以與Spring環境無縫集成，你可以像使用Spring Bean一樣來使用KafkaProducer和KafkaConsumer。
構建Producer示例：
構建Consumer示例：
服務源碼注解
kclient提供了類似Spring聲明式的編程方法，使用注解聲明Kafka處理器方法，所有的線程模型、異常處理、服務啟動和關閉等都由后台服務自動完成，極大程度的簡化了API的使用方法，提高了開發者的工作效率。
注解聲明Kafka消息處理器：
注解啟動程序：
注解Spring環境配置：
API簡介 Producer API
KafkaProducer類提供了豐富的API來發送不同類型的消息，它支持發送字符串消息，發送一個普通的Bean，以及發送JSON對象等。在這些API中可以指定發送到某個Topic，也可以不指定而使用默認的Topic。對於發送的數據，支持帶Key值的消息和不帶Key值的消息。
發送字符串消息:
發送Bean消息:
發送JSON對象消息:
Consumer API
KafkaConsumer類提供了豐富的構造函數用來指定Kafka消費者服務器的各項參數，包括線程池策略，線程池類型，流數量等等。
使用PROPERTIES文件初始化:
---------------------
原文：https://blog.csdn.net/lr131425/article/details/71159243