logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

Spring-Kafka 3.0 消费者消费失败处理方案

我们作为Kafka在使用Kafka是,必然考虑消息消费失败的重试次数,重试后仍然失败如何处理,要么阻塞,要么丢弃,或者保存Kafka3.0 版本默认失败重试次数为10次,准确讲应该是1次正常调用+9次重试,这个在这个类可以看到 org.springframework.kafka.listener.SeekUtils据我的实验,spring-kafka3.0版本通过application.yml 配

文章图片
#spring#kafka#java
SpringBoot 3.1.7 集成Kafka 3.5.0

写这边篇文章的目的,是记录我在集成kafka客户端遇到的一些问题,文章会记录整个接入的过程,其中会遇到几个坑,如果需要最终版本,直接看最后一节就行了,感觉Spring-Kafka的文档太少了,如果采用SpringBoot集成的方式接入,一不小可能就会踩坑。在org.springframework.kafka.annotation.KafkaListener 类的注释上面有写到可以使用org.spr

文章图片
#spring boot#kafka
SpringBoot3.1.7集成Kafka和Kafka安装

从 Kafka 2.8.0 版本开始,KRaft 模式已经被正式引入,在 KRaft 模式下,ZooKeeper 不再是必需的,既然kafka团队有意要去除对zookeeper的依赖,那我们也顺应趋势,使用KRaft模式启动。Kafka 因为是强依赖zookeeper的,所以必须要先启动zookeeper,不过好在Kafka帮我们把zookeeper的包都准备好了,放在libs目录下面,并且启动脚

文章图片
#kafka#分布式#centos +1
电商系统设计到开发03 引入Kafka异步削峰

电商系统设计到开发01 第一版设计到编码-CSDN博客电商系统设计到开发02 单机性能压测-CSDN博客本篇为大制作,内容有点多,也比较干货,希望可以耐心看看已经开发的代码,并对其下单接口进行了压力测试压力测试,该接口一个请求需要查询数据库4次,更新4次 ,插入2次,总共访问数据库10次,其中2个事务,3次查询是加锁查询,还有 1 次 rpc 请求,单实例情况下吞吐量为110/s今天我们将其引入K

文章图片
#kafka#分布式#java
Openresty+Lua+Redis实现高性能缓存

OpenResty® 是一个基于Nginx与 Lua 的高性能 Web 平台,其内部集成了大量精良的 Lua 库、第三方模块以及大多数的依赖项。用于方便地搭建能够处理超高并发、扩展性极高的动态 Web 应用、Web 服务和动态网关。官网:OpenResty® - 开源官方站Lua 是一个小巧的脚本语言。

文章图片
#缓存#openresty#lua +1
Golang开发工具

Golang开发工具1. GolandGoland 是一个Go语言IDE下载地址: https://www.jetbrains.com/go/download/#section=windows2. VS Code+ Go插件(免费)VSCode也支持Go, 只需要把Go相关插件集成进去即可下载地址:https://code.visualstudio.com/3. IDEA + Go 插件IDEA

文章图片
#golang#ide
到底了