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