Springboot 1.5.7整合Kafka-client代码示例
更新时间：2020年10月29日 11:52:41 作者：马云12314
这篇文章主要介绍了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集成 结束-->
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
这篇文章主要介绍了Java中BorderLayout布局管理器的两种排列方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2022-12-12
这篇文章主要给大家介绍了关于java字符串转JSON的相关资料,JSON 是一种轻量级的数据交换格式,常用于Web应用程序中的数据传输,文中通过代码示例介绍的非常详细,需要的朋友可以参考下2023-09-09
在MyBatis中,默认情况下,获取的SqlSession对象不会自动提交事务,这意味着在进行更新、删除或插入等操作后,需要显式调用commit方法来提交事务,但是,可以在获取SqlSession时通过将openSession方法的参数设置为true2024-09-09
子类可以在父类的基础上改写父类内容，为了避免这种随意改写的情况，Java提供了final 关键字，用于修饰不可改变内容。本文就来详细说说final关键字的使用，需要的可以参考一下2022-10-10
OpenFeign是Spring Cloud在Feign的基础上支持了SpringMVC的注解，如@RequesMapping等等，这篇文章主要介绍了OpenFeign服务调用的相关知识,需要的朋友可以参考下2022-07-07
MyBatis 是一款优秀的 ORM 框架，它提供了多种配置方式来定义 SQL 语句以及结果映射规则，本文将介绍 MyBatis 中的 SQL 映射文件如何配置结果映射，包括常规类型、集合类型等多种情况,需要的朋友可以参考下2023-07-07
这篇文章主要给大家介绍了关于Java面向对象和内存分析的相关资料，文章可以让初学者顺利的分析内存，更加容易的体会程序执行过程中内存的变化，需要的朋友可以参考下2021-05-05
Spring Boot + Spring Batch 实现批处理任务的详细教程
这篇文章主要介绍了Spring Boot+Spring Batch实现批处理任务,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2023-08-08
mybatis if test判断BigDecimal遇到的坑及解决
这篇文章主要介绍了mybatis if test判断BigDecimal遇到的坑及解决方案，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2023-03-03
在web开发中，拦截器是经常用到的功能。它可以帮我们预先设置数据以及统计方法的执行效率等等。今天就来详细的谈一下spring中的拦截器，需要的可以参考一下2022-06-06
最新评论