Springboot 1.5.7整合Kafka-client代码示例

在一次项目中，因甲方需要使用kafka消息队列推送数据，所以需要接入kafka，并且kafka的版本是2.11。但是我们项目使用的是springboot 1.5.7的版本，对应的springboot.kafka.starter有冲突，所以就接入了kafka-client。

kafka 是一个分布式消息引擎与流处理平台，经常用做企业的消息总线、实时数据管道，有的还把它当做存储系统来使用。
早期 kafka 的定位是一个高吞吐的分布式消息系统，目前则演变成了一个成熟的分布式消息引擎，以及流处理平台。

kafka 主要起到削峰填谷（缓冲）、系统解构以及冗余的作用，主要特点有：

• 高吞吐、低延时：这是 kafka 显著的特点，kafka 能够达到百万级的消息吞吐量，延迟可达毫秒级；
• 持久化存储：kafka 的消息最终持久化保存在磁盘之上，提供了顺序读写以保证性能，并且通过 kafka 的副本机制提高了数据可靠性。
• 分布式可扩展：kafka 的数据是分布式存储在不同 broker 节点的，以 topic 组织数据并且按 partition 进行分布式存储，整体的扩展性都非常好。
• 高容错性：集群中任意一个 broker 节点宕机，kafka 仍能对外提供服务。

springboot接入kafka-client还是比较简单的，这里只是做一个记录。

pom文件中添加如下依赖即可

<!-- kafka集成 开始-->
    <dependency>
      <groupid>org.apache.kafka</groupid>
      <artifactid>kafka-clients</artifactid>
      <version>2.0.1</version>
    </dependency>
    <dependency>
      <groupid>org.springframework.kafka</groupid>
      <artifactid>spring-kafka</artifactid>
      <version>1.1.8.release</version>
      <exclusions>
        <exclusion>
          <groupid>org.apache.kafka</groupid>
          <artifactid>kafka-clients</artifactid>
        </exclusion>
      </exclusions>
    </dependency>
    <!-- kafka集成 结束-->

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。