51工具盒子

依楼听风雨
笑看云卷云舒,淡观潮起潮落

日常运维

Spring 配置 Kafka 死信队列

Spring 配置 Kafka 死信队列

厉飞雨 阅读(16) 评论(0) 赞(3)

1、简介 {#1简介} ----------- 本文将带你了解如何在 [Spring](/spring/) 中为 Apache Kafka 配置死信队列。 2、死信队列 {#2死信队列} --------------- 死信队列(Dead Letter Queue,DLQ)用于存储由于各种原因无法正确处理的消息,例如间歇性系统故障、无效的消息模式或损坏的内容。这些消息可以...

在 Spring Boot 中处理 Kafka Offset(偏移量)

在 Spring Boot 中处理 Kafka Offset(偏移量)

厉飞雨 阅读(26) 评论(0) 赞(2)

本文将带你了解如何使用 [Spring Boot](/spring-boot/) 和 [Spring Kafka](/spring-kafka/) 管理 Kafka 消费者偏移量(Offset)。 在之的一篇文章中,主要说明了应用处理 Kafka 消息的方式可能会影响系统的整体性能,并没有考虑消费者端的消息重复或消息丢失等问题。本文将会介绍这些话题。 1、源码 {#1源码}...

在 Spring Boot 中动态管理 Kafka Listener

在 Spring Boot 中动态管理 Kafka Listener

厉飞雨 阅读(13) 评论(0) 赞(4)

1、概览 {#1概览} ----------- 本文将带你了解如何在 [Spring Boot](/spring-boot/) 应用中动态地启动和停止 Kafka Listener。 2、依赖 {#2依赖} ----------- 首先,添加 [*spring-kafka*](https://mvnrepository.com/artifact/org.springfra...

通过 CLI 命令行发送 Key/Value 消息到 Kafka

通过 CLI 命令行发送 Key/Value 消息到 Kafka

厉飞雨 阅读(16) 评论(0) 赞(3)

1、概览 {#1概览} ----------- 本文将带你了解从 Kafka 命令行(CLI)发送 Key/Value 消息的两种方法。 在处理金融交易、预订、在线购物等实时事件驱动系统中,确保特定 Topic 上消息的有序性是一个常见需求。在这种情况下,我们应该为发送到这些 Topic 的事件使用 *Kafka Message Key*。 2、先决条件 {#2先决条件}...

Kafka 中的 InstanceAlreadyExistsException 异常

Kafka 中的 InstanceAlreadyExistsException 异常

厉飞雨 阅读(21) 评论(0) 赞(4)

1、简介 {#1简介} ----------- [*Apache Kafka*](https://kafka.apache.org/) 是一个功能强大的分布式流平台,被广泛用于构建实时数据管道和流应用。然而,Kafka 在运行过程中可能会遇到各种异常和错误。其中一个常见的异常就是 `InstanceAlreadyExistsException`。 本文将带你了解 *Kafk...

jumpserver admin 此账号已禁用

jumpserver admin 此账号已禁用

厉飞雨 阅读(35) 评论(0) 赞(5)

jumpserver admin 此账号已禁用 ![](http://static.51tbox.com/static/2024-08-29/col/aa8179b22900e324b9c6fbe386f0744d/f1bf2831206c41ac9d7f27144367c912.png.jpg) ### 解决办法 我是docker 版本: [jumpserver管理员...

jumpserver 升级

jumpserver 升级

厉飞雨 阅读(38) 评论(0) 赞(3)

参考: [Linux:jumpserver V3的安装与升级(在线\&\&离线)(2)_jumpserver升级-CSDN博客](https://blog.csdn.net/w14768855/article/details/135187970) 一台windows服务器, 加入 jumpserver v3.7.1 失败,但是同样的配置 加入 v3.10.1...

第4步 webhook

第4步 webhook

厉飞雨 阅读(40) 评论(0) 赞(4)

第4步 webhook 希望每次修改完项目, 代码推送,流水线能自动运行。 写代码提交--》 gitee --》 给指定的地方发请求(wehoook) --\>kubesphere 平台感知到 --》启动流水线继续运行。 1)gitee 设置 ![](http://static.51tbox.com/static/2024-08-29/col/057f61953a...