Kafka使用kclient三种使用方法

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