springboot整合kafka附源码

2023-12-21 11:51:00

前提:确保kafka环境
我使用的方案是docker
我使用的镜像为:wurstmeister/kafka
我使用的镜像为:wurstmeister/zookeeper
docker安装kafka和zk教程:点这里手把手教你使用Docker搭建kafka【详细教程】

使用kafka前,要确保你对kafka有一个基本的了解,如topic(可以看成是rabbitmq的队列),分区,offset,生产者,消费者,消费者组等

此教程源码地址:https://gitee.com/jackXUYY/springboot-example.git

拉下代码之后,改一下kafka的地址为自己的kafka地址,然后把事务配置先注释掉
配置文件里的transaction-id-prefix属性
检查项目能否正常启动

我们先试一下简单的生产消费

在这里插入图片描述

在这里插入图片描述

发送消息
在这里插入图片描述

消费者
在这里插入图片描述

打印结果
在这里插入图片描述

再试一下发送消息带回调的方式

在这里插入图片描述
在这里插入图片描述

发送和消费结果
在这里插入图片描述

我们再试一下事务消息

生产者事务发送:需配置transaction-id-prefix开启事务

在这里插入图片描述

在这里插入图片描述

在这里插入图片描述
结果
在这里插入图片描述

再试一下第二种事务发送

在这里插入图片描述

结果
在这里插入图片描述

自定义分区规则,CustomizePartitioner

我们把这个类的注释打开,同时配置文件里的,partitioner.class配置开启,把消费者组group-id改为mykafka2,再把事务的配置也注释掉

在这里插入图片描述
把上面的方法注释掉,把此方法的注释打开
在这里插入图片描述

发送一个符合分区的消息内容
在这里插入图片描述
因为此时没有1号分区,消息会发送超时

我们可以新建配置类,声明分区数

在这里插入图片描述
然后在发送消息试一下

在这里插入图片描述
后续,刚才我们是手动ack,提交偏移量

我们也可以指定偏移量去消费,方法代码里都有的,这里就截图了
在这里插入图片描述

批量消费

在这里插入图片描述
过滤消息内容再进行消费,异常处理

在这里插入图片描述

消息转发

在这里插入图片描述
定时启动,停止监听器

在这里插入图片描述

生产者如何提高吞吐量

在这里插入图片描述

在这里插入图片描述
参考博客:https://blog.51cto.com/u_14452299/6019881

思考,如果其他中间件或框架,想要自定义配置的话,那可能也会继承它的接口,重写方法,或者声明自己的配置类啥的

文章来源:https://blog.csdn.net/qq_44909430/article/details/135123257
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。