Springboot 1.5.7整合Kafka

网友投稿 289 2022-11-15


Springboot 1.5.7整合Kafka

在一次项目中,因甲方需要使用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文件中添加如下依赖即可

org.apache.kafka

kafka-clients

2.0.1

org.springframework.kafka

spring-kafka

1.1.8.RELEASE

org.apache.kafka

kafka-clients

&lthttp://;!-- kafka集成 结束-->


版权声明:本文内容由网络用户投稿,版权归原作者所有,本站不拥有其著作权,亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容,请联系我们jiasou666@gmail.com 处理,核实后本网站将在24小时内删除侵权内容。

上一篇:Java BufferedReader相关源码实例分析
下一篇:如何开发一个简单的Akka Java应用
相关文章

 发表评论

暂时没有评论,来抢沙发吧~