轻松上手 Spring Boot & Kafka 实战!

供稿:hz-xin.com     日期:2025-01-16
Kafka集群安装、配置和启动

Kafka需要依赖zookeeper,并且自身集成了zookeeper,zookeeper至少需要3个节点保证集群高可用,下面是在单机linux下创建kafka3个节点伪集群模式。

1、下载包

下载地址: kafka.apache.org/downlo...

2、解压包

tar -zxvf kafka_2.11-1.0.0.tgz mv kafka_2.11-1.0.0 kafka1 mv kafka_2.11-1.0.0 kafka2 mv kafka_2.11-1.0.0 kafka3

3、创建ZK集群

修改ZK配置文件:kafka1-3/config/zookeeper.properties分别修改对应的参数。

/usr/local/kafka/zookeeper1-3目录下分别创建myid文件,内容对应1~3

启动ZK,分别进行Kafka1-3目录:

bin/zookeeper-server-start.sh config/zookeeper.properties &

启动报文件失败,需要手动创建文件目录并赋予对应的权限。

4、创建Kafka集群

配置文件:kafka1-3/config/server.properties分别修改对应的参数。

启动Kafka,分别进行Kafka1-3目录:

bin/kafka-server-start.sh config/server.properties &

启动报文件失败,需要手动创建文件目录并赋予对应的权限。

5、集群测试

在kafka1上面发送消息:

bin/kafka-console-producer.sh --broker-list localhost:9091 --topic test

在kafka2、kafka3消费消息:

bin/kafka-console-consumer.sh --zookeeper localhost:2181 --from-beginning --topic my-replicated-topic

Spring Boot 集成 Kafka 实战

1、添加spring-kafka依赖

2、添加Spring Boot的自动配置

自动配置类:

org.springframework.boot.autoconfigure.kafka.KafkaAutoConfiguration

配置属性类:

org.springframework.boot.autoconfigure.kafka.KafkaProperties

3、发送消息

4、接收消息

在任何bean里面,添加@KafkaListener,支持消息接收。

5、参考资料

Spring Boot & Kafka官方文档:

docs.spring.io/spring-b...

Spring for Apache Kafka官方文档:

记得关注我,分享更主流的Java技术~

更多 Spring Boot 干货:

Spring Boot 宣布移除 run 命令,真让我猝不及防!

Spring Boot 定时任务开启后,怎么符合条件自动停止?

Spring Boot 保护敏感配置的 4 种方法,让你的系统不再裸奔!!

Spring Boot 集成 Flyway,数据库也能做版本控制,太牛逼了!

54 个官方 Spring Boot Starters 出炉!别再重复造轮子了……

Spring Boot Redis 实现分布式锁,真香!!

Spring Boot 之配置导入,强大到不行!

年轻人的第一个自定义 Spring Boot Starter!

Spring Boot 面试,一个问题就干趴下了!(下)

Spring Boot 最核心的 25 个注解,都是干货!

好了,最后栈长再送你一份Spring Boot 学习笔记,包括底层实现原理及代码实战,非常齐全,助你快速打通 Spring Boot 的各个环节。

链接: pan.baidu.com/s/15wLzA6... 提取码: ztsj

最后,别忘了点在看、转发哦,需要你的鼓励~

springboot的两大特性?
ssm和springboot的区别二者主要区别是:1、SpringBoot提供极其快速和简化的操作,让Spring开发者快速上手。2、SpringBoot提供了Spring运行的默认配置。3、SpringBoot为通用Spring项目提供了很多非功能性特性,例如:嵌入式Serve、Security、统计、外部配置等等。为什么越来越多的开发者选择使用SpringBoot(1)Spring...

SpringBoot配置入门
Spring Boot 是构建所有基于 Spring 的应用程序的起点。它旨在让开发者迅速启动项目,同时减少 Spring 配置文件的编写。Spring Boot 的引入简化了项目搭建流程,让开发者能够更加专注于业务逻辑的实现。相较于传统的Spring项目搭建,使用Spring Boot可以显著减少配置文件的编写。搭建过程变得更为简洁,只需通过...

springboot框架简介(springboot框架简介优点)
springboot框架的优点Springboot只是为了提高开发效率,而且是为了提高生产力:springboot一个使用是一个可执行的jar(启动类的main方法来启动web使用),不像传统的war嵌入了tomcat容器。它可以以jar的形式启动服务,并快速部署和发布web服务。它可以省去之前繁琐的编辑配置文件的过程,采用大量的默认配置来简化...

spring和springboot区别
2、SpringBoot提供了Spring运行的默认配置。3、SpringBoot为通用Spring项目提供了很多非功能性特性,例如:嵌入式Serve、Security、统计、健康检查、外部配置等等。Spring是一个开放源代码的设计层面框架,他解决的是业务逻辑层和其他各层的松耦合问题,因此它将面向接口的编程思想贯穿整个系统应用。Spring是于...

Spring Boot从入门到精通-项目搭建
Spring Boot极大的简化了java项目的开发,在之前如果想要开发一个java项目,需要安装tomcat或者其他容器插件。但是Spring Boot内部已经集成了tomcat,因此项目的启动异常的方便。而且Spring Boot的开发中有很多默认的配置,帮助我们省去了相当多的时间。在idea中,File-->New-->Project...选择Spring Initializr...

【项目实战SpringBoot+Vue】基于easyexcel实现Excel大数据量的导入导出...
【项目实战SpringBoot+Vue】通过EasyExcel实现Excel大数据量的高效导入导出,轻松应对数据脱敏需求。实战过程中,我们展示了以下关键环节:导入数据:通过多种方式实现,包括简单方法、匿名内部类、自定义ReadListener等,每种方法都适合不同场景的需求。导出Excel:同样提供多种写法,简单导出和多Sheet页导出,满足...

springboot干什么用的(springboot有什么)
因为SpringBoot解决的问题(1)SpringBoot使编码变简单(2)SpringBoot使配置变简单(3)SpringBoot使部署变简单(4)SpringBoot使监控变简单(5)Spring的不足 什么是SpringBoot? SpringBoot可以轻松创建独立的、生产级的基于Spring的应用程序,您可以“直接运行”这些应用程序。 我们对Spring平台和第三方库采取了固执的观点,因此...

springboot框架的理解
springboot帮我们做的两件事,一个是通过starter引入我们需要的框架,starter负责引入自己的依赖;另一个是通过autoconfigure生效一些默认的配置,简化我们的使用,这一步是通过spring.factories中定义的配置类实现的。SpringBoot是由Pivotal团队提供的全新框架,其设计目的是用来简化新Spring应用的初始搭建以及开发...

项目中springboot大多用来做什么(springboot项目优点)
微服务一定要用springboot吗spring-boot:较springmvc更加简约了,springmvc有一大零的配置文件,比如spring-servlet、spring-mybatis、spring.xml与web.xml,这些在spring-boot都不需要了,只需要强大的注解功能即可,boot更合适微服务。首先你的问题应该写错了,应该是目前比较流行的微服务开发框架,而不是比较...

springboot框架的优点
Spring Boot 可以轻松创建可以“直接运行”的独立的、生产级的基于 Spring 的应用程序。我们对 Spring 平台和第三方保持固执己见的看法,因此您可以轻松上手。大多数 Spring Boot 应用程序需要最少的时间 Spring 配置。其特征如下:创建独立的 Spring 应用程序 直接嵌入 Tomcat、Jetty 或 Undertow(无需...