kafka消费堆积，但是每次消费操作数据库时间很长，如果增加消费者或者新增分区，可能会导致数据库死锁。友友们有没有办法支援下
0条回答 默认 最新
- 2024-06-12 09:00夏之以寒的博客 Kafka作为一款高性能的分布式消息队列系统，在处理消费者故障和活锁问题时表现出了卓越的性能和稳定性。通过消费者组、偏移量提交、自动重平衡等机制以及优化消息处理逻辑、设置合理的超时时间、引入优先级机制和...
- 2025-05-26 16:58AGI大模型与大数据研究院的博客 在大数据时代，Kafka作为一款高性能、分布式的消息队列系统，被广泛应用于数据采集、流处理、日志收集等众多场景。对Kafka消息队列进行有效的监控是保障系统稳定运行、提升性能的关键。本文章的目的在于深入探讨...
- 2022-08-29 21:34阿兴呢！！！的博客 Kafka中产生数据积压的原因以及解决方案。
- 2025-03-05 00:03小技工丨的博客 还是可能会导致数据丢失的，如果刚写入leader，leader就挂了，此时数据必然丢了，其他的follower没收到数据副本，变成leader 4.8 Kafka如何不重复消费数据 保存并查询 给每个消息都设置一个独一无二的key,消费的时候...
- 2023-10-17 14:14cjpp老白的博客 kafka、ck、flink等实时组件的热门问题
- 2021-07-04 21:35Shockang的博客 我们都知道，消息积压的直接原因，一定是系统中的某个部分出现了性能问题，来不及处理上游发送的消息，才会导致消息积压。 所以，我们先来分析下，在使用消息队列时，如何来优化代码的性能，避免出现消息积压。 然后...
- 2024-12-27 13:52geekspot的博客 一、zookeeper简介 中间件常见的消息队列 / 消息中间件：1.1 zookeeper的概述ZooKeeper是一个分布式的，开放源码的分布式应用程序协调服务，是Google的Chubby一个开源的实现，是Hadoop和Hbase的...解决死锁例如：堵车。
- 2025-05-07 17:10dyf040508的博客 Kafka 是最初由 Linkedin 公司开发，是一个分布式、支持分区的（partition）、多副本的（replica），基于 Zookeeper协调的分布式消息中间件系统，它的最大的特性就是可以实时的处理大量数据以满足各种需求场景，比如...
- 2024-12-19 19:15程序员的第11小时的博客 kafka，消息中间件，消息队列，读书笔记
- 2024-06-28 00:40AI天才研究院的博客 而在Flink的Batch SQL任务中,经常会遇到Backpressured的问题,导致任务运行缓慢甚至失败。因此,深入理解Backpressured的原理,并能够在实践中加以应用,对于保证Flink Batch SQL任务的稳定性和效率至关重要。
- 没有解决我的问题, 去提问
问题事件
系统已结题
11月5日
创建了问题
10月28日