kafka消费失败重试机制

kafka批量消费时,消息消费失败处理

7.6 SpringBoot AOP实战 统一角色权限校验

通过上文7.5 SpringBoot 拦截器Interceptor实战 统一角色权限校验,很多朋友学会了Interceptor实现以后,很想学习如何使用AOP实现 统一角色权限校验,所以本文就来安排AOP的实现!对于SpringBoot的AOP的相关基础知识,请参考我之前写过的博客,也是上过综合热榜

【国产化信创实践】宝兰德bes中间件集成springboot

【国产化信创实践】宝兰德bes中间件集成springboot

Docker笔记之DockerCompose+yaml详解

resources:配置服务器资源使用的限制,例如上例子,配置 redis 集群运行需要的 cpu 的百分比 和 内存的占用。order:回滚期间的操作顺序。其中一个 stop-first(串行回滚),或者 start-first(并行回滚)(默认 stop-first )。其中一个 stop-fi

kafka基础

kafka是一个消息队列的中间件,那什么是消息队列?生产者:负责生产消息,将消息发送给broker,是全部消息的发起者。broker:是消息的服务端,负责消息的存储、投递等功能,是最核心的部分。消费者:负责消息的消费,根据消息承载的信息处理对应逻辑。它的应用场景有:消息的异步处理:比如用户注册发送验

Spring Boot如何实现配置文件的自动加载和刷新?

在本文中,我们介绍了Spring Boot如何实现配置文件的自动加载和刷新。配置文件是应用程序的重要组成部分,而配置文件的自动加载和刷新可以使应用程序更加灵活和可配置。我们讨论了基于轮询和基于Webhook的配置文件刷新方式,并给出了相应的示例代码。在实践中,我们需要注意一些细节,例如配置文件中属性

SpringBoot 统一功能的处理

/定义拦截器 @Component public class LoginInterceptor implements HandlerInterceptor {

SpringBoot中使用Kafka报错:Failed to construct kafka consumer

报错内容在SpringBoot项目中使用了Kafka,在启动的过程中报错2022-02-26 11:44:10.422 ERROR 26148 --- [ main] o.s.boot.SpringApplication : Application r

Spring 从Postman发送的数据,后端接受变成null了?!

今天遇到了个奇怪的问题,用Postman给后端发JSON格式的数据,结果,发来全是null,在网上找了很多方法都不行。结果如下,可以看到已经可以收到(id是null是我故意设置的),数据库也可以看到响应数据!接受相关JSON的Mapping。Postman发送的数据。设计的domain类。

mybatis-plus 多表关联条件分页查询

mybatis-plus 多表关联分页 条件查询

带你一文吃透Git

Git 是一个分布式版本控制工具,通常用来对软件开发过程中的源代码文件进行管理。本地仓库:开发人员自己电脑上的 Git 仓库远程仓库:远程服务器上的 Git 仓库commit:提交,将本地代码和版本信息保存到本地仓库push:推送,将本地仓库文件和版本信息上传到远程仓库pull:拉取,将远程仓库文件

Java分页查询的几种实现方法

Java实现分页查询的两种方式

Springboot线上环境彻底关闭Swagger-UI

2.创建一个控制类使用@Profile仅线上环境生效,使访问swagger-ui.html返回404。通过这种方式可以彻底关闭线上环境访问swagger-ui.html直接返回404。1.SwaggerConfig使用@Profile排除线上环境其他环境生效。Springboot线上环境彻底关闭Sw

IDea创建Spring或Maven项目缺少src、main、java等文件解决办法

2、点击左上角File,选择项目结构。3、选择Modules。

解决IDEA,Cannot resolve org.springframework.boot,Build报错的问题

Cannot resolve plugin org.springframework.boot:spring-boot-maven-plugin:2.7.8

Flink流批一体计算(11):PyFlink Tabel API之TableEnvironment

编写 Flink Python Table API 程序的第一步是创建 TableEnvironment。这是 Python Table API 作业的入口类。get_config()返回 table config,可以通过 table config 来定义 Table API 的运行时行为。

使用hutool工具发送post请求

使用hutool工具发送post请求

线程异常WAITING(parking)

项目中线程数量持续增长,且基本无法回收关闭,线程数量一直累积达到几万,影响CPU开销和性能,导致服务器卡死

Mven安装配置、配置国内镜像,jdk17版本、配置maven环境变量

Mven安装配置、配置国内镜像,jdk17版本、配置maven环境变量

flink cdc报错

执行flink cdc 报错,ClassNotFoundException: org.apache.kafka.common.utils.ThreadUtils

登录可以使用的更多功能哦! 登录
作者榜
...
资讯小助手

资讯同步

...
内容小助手

文章同步

...
Deephub

公众号:deephub-imba

...
奕凯

公众号:奕凯的技术栈