springboot整合kafka附源码

前提:确保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

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

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/261063.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

字符串函数内存函数(从零到一)【C语言】

长度不受限制的字符串函数:strcpy,strcat,strcmp 长度受限制的字符串函数:strncpy,strncat,strncmp strlen strlen函数是库函数中我们最常使用的函数,它可以求出字符串的长度(不包含‘\0’) 使用方法 通过前面对strlen函数的模拟实现我们知…

考研小白助力宝典(2)

前言 考研,是一场耗时长久的脑力之战,刻苦勤奋的态度和披荆斩棘的精神外,往往取决于谁抓好了信息利剑!合理得当利用好信息平台,就已经快人一步战胜了大部分的竞争对手了! 目录 着重学习练习 考研相关简介 …

小白向攻略简单易懂,怎么用DomoAI将手机里面的视频转换成丝滑流畅高帧数的动画

Domo AI是一款强大的人工智能工具,支持图像和视频的重新创作。它拥有超过10个多样化的预设模型,使用户能够轻松实现一致且统一的艺术风格。 在图像生成方面,Domo AI能够快速将照片转换成动漫或现实风格,同时还支持将素描或线稿重…

关于“Python”的核心知识点整理大全33

目录 12.8.3 将子弹存储到编组中 alien_invasion.py 注意 12.8.4 开火 game_functions.py 12.8.5 删除已消失的子弹 alien_invasion.py 12.8.6 限制子弹数量 settings.py game_functions.py 12.8.7 创建函数 update_bullets() game_functions.py alien_invasion.py…

redhawk中short引起的ir drop为0的情况

我正在「拾陆楼」和朋友们讨论有趣的话题,你⼀起来吧? 拾陆楼知识星球入口 问题如图,顶层在做redhawk分析时读了top及block的def,但top def中并没有把block pg pin写到top 的pg net下,导致redhawk认为有short存在&…

获投1050万欧元!德国量子公司Kipu Quantum成功研发特定压缩算法

​(图片来源:网络) 近日,德国量子软件公司Kipu Quantum宣布成功完成种子轮融资,融资总额达1050万欧元(约合8000万人民币)。该初创公司目前已开发出运行高性能量子计算机所需的压缩算法。该算法…

迎接新技术挑战,JFrog发布与升级系列黑科技技术产品

作为开发者,我们十分关注软件开发的全生命周期,有一家企业也同样关注软件交付和流式软件,致力创造从开发人员到设备之间畅通无阻的软件交付世界。它便是 JFrog,自2008年成立以来,目前已在全球范围内拥有7200家客户&…

2024年天津理工大学中环信息学院专升本报名考务费网上缴费说明

2024年天津理工大学中环信息学院高职升本考试报名考务费网上缴费说明 通过资格审核的考生,须在2023年12月22日至12月25日每天8:00-17:00完成考务费缴费,网上缴费参照津发改价费【2020】371号文件,左右考试考务费:80元&#xff08…

Apache ShenYu 网关JWT认证绕过漏洞 CVE-2021-37580

Apache ShenYu 网关JWT认证绕过漏洞 CVE-2021-37580 已亲自复现 漏洞名称漏洞描述影响版本 漏洞复现环境搭建漏洞利用 修复建议总结 Apache ShenYu 网关JWT认证绕过漏洞 CVE-2021-37580 已亲自复现) 漏洞名称 漏洞描述 Apache ShenYu是一个异步的,高性能的&#x…

如何在 FastAPI 中设置定时任务:完全指南

Web 应用程序开发中,及时高效处理常规任务至关重要,包括定时收集数据或管理任务计划。针对强大且性能卓越的 FastAPI 框架,我们可以通过几种策略来管理这些必要的定时任务。 实现 FastAPI 中的定时任务 本指南将探讨在 FastAPI 环境中管理定…

Git初始

一)git的介绍: 1)假设现在有一个文档,你的老板要求你针对于这份文件进行修改,进行完成的修改的版本是版本1,接下来是文档2,修改完文档2以后,接下来老板还不同意,于是又有了文档三,文档四&#x…

Ubuntu 常用命令之 less 命令用法介绍

📑Linux/Ubuntu 常用命令归类整理 less命令是一个在Unix和Unix-like系统中用于查看文件内容的命令行工具。与more命令相比,less命令提供了更多的功能和灵活性,例如向前和向后滚动查看文件,搜索文本,查看长行等。 les…

算法和算法分析

一个问题抽象为一个抽象数据类型后,仅是形式上的抽象定义,还没有达到问题解决的目的,要实现这个目标,就要吧抽象的变成具体的,即抽象数据类型再计算机上实现,变为一个能用的具体的数据类型! …

Unity | Shader基础知识(第八集:案例<漫反射材质球>)

目录 一、本节介绍 1 上集回顾 2 本节介绍 二、什么是漫反射材质球 三、 漫反射进化史 1 三种算法结果的区别 2 具体算法 2.1 兰伯特逐顶点算法 a.本小节使用的unity自带结构体。 b.兰伯特逐顶点算法公式 c.代码实现——兰伯特逐顶点算法 2.2 代码实现——兰伯特逐…

如何开启In-sensor zoom 功能

和你一起终身学习,这里是程序员Android 经典好文推荐,通过阅读本文,您将收获以下知识点: 一、In-sensor zoom 概述二、如何开启 In-sensor zoom2.1 开启 camxsettings.xml setting2.2 多摄像头,需要添加特殊的逻辑2.3 在 MetaTran…

记录下IAP升级将APP程序修改正常模式下载失败 No Algorithm found for: 08000000H - 08008FFFH

移植发现问题: No Algorithm found for: 08000000H - 08008FFFH 今天在调试程序时,需要把钱同事程序的APP修改成成正常下载就可以用的程序,工程的地址复位也把APP的偏移地址去掉,理论上这样就OK了 偏移地址设置也屏蔽了 STLINK下…

美摄AE模板插件工具,将美摄SDK和AE极致融合

视频内容已经成为企业宣传和品牌建设的重要手段,为了满足企业对于高质量视频制作的需求,美摄科技推出了一款创新性的插件工具——美摄AE模板插件工具。这款工具将美摄SDK能力和Adobe After Effects极致融合,为企业提供了一种快速制作和转化美…

vue 历程记

目录 前言一、源码优化1、vue3.x 采用 monorep 的理念来管理源码2、vue3.x 源码采用 TypeScript 开发 二、性能优化1、减少源码的体积2、数据劫持优化3、编译优化(1)、编译粒度的优化 三、语法 API 的优化1、优化了编码的逻辑组织2、优化了代码的逻辑复用…

Java学习系列(四)

1.Scanner类 java.util.Scanner 是 Java5 的新特征,我们可以通过 Scanner 类来获取用户的输入。 import java.util.Scanner; public class ScannerDemo {public static void main(String[] args) {Scanner scan new Scanner(System.in);// 从键盘接收数据// next…

css学习笔记2

css学习笔记2 CSS三大特性1.三大特性1.1层叠性1.2继承性1.3优先级 2.颜色的表示2.1表示方式一:颜色名2.2表示方式二:rgb或rgba2.3表示方式三:HEX或HEXA2.4表示方式四:HSL或HSLA CSS三大特性 1.三大特性 1.1层叠性 概念&#xff…