kafka消费堆积，但是每次消费操作数据库时间很长，如果增加消费者或者新增分区，可能会导致数据库死锁。友友们有没有办法支援下
0条回答 默认 最新
- 2022-08-23 10:01回答 1 已采纳 同一个消费组能同时消费的消费者数量和topic的分区数有关，估计是你的topic只有两个分区所以使用相同的groupid只有两个消费者在消费，加一个分区就好
- 2022-10-25 09:26回答 5 已采纳 感觉消息堆积有点厉害，查一下代码，是因为什么原因导致消息一直没被消费。如果只是前端数据，可以丢弃的话，把队列清空，看看还会不会卡？
- 2022-12-21 00:45回答 1 已采纳 这篇博客也许可以解决你的问题👉 ：kafka消费者从kafka读取信息
- 2024-06-12 09:00夏之以寒的博客 Kafka作为一款高性能的分布式消息队列系统，在处理消费者故障和活锁问题时表现出了卓越的性能和稳定性。通过消费者组、偏移量提交、自动重平衡等机制以及优化消息处理逻辑、设置合理的超时时间、引入优先级机制和...
- 2022-01-10 15:46回答 3 已采纳 消费者和生产者与机器无关，这是不同的概念，消费者与生产者只是在Kafka中的角色，不同角色干不同的事情
- 2021-07-05 16:53回答 1 已采纳 value的值为[B@1e1e585b这个明显是序列化后的Bytes字节类型嘛你反序列化成string就ok了
- 2021-07-02 11:07回答 2 已采纳 对kafka来说，只要这条数据发出去了，就算消费了，你消费者怎么处理，和kafka无关了。对消费者来说， 你只需要消费下一条就行了。至于偏移量， 你第一次消费的时候，是要发送偏移的，这个你消费者要本地
- 2022-08-29 21:34阿兴呢！！！的博客 Kafka中产生数据积压的原因以及解决方案。
- 2022-06-11 10:41回答 1 已采纳 给你个例子，是可以收发的。验证通过再和你的对比一下，你应该哪里配错了。 springboot集成kafka、消息发送、消费使用_‘’小磊的博客-CSDN博客_spri
- 2017-02-01 18:07回答 2 已采纳 The consumer group is specified by the second argument of the cluster consumer "constructor". Here
- 2022-01-28 09:47回答 1 已采纳 那最后写入到库了吗，如果写不进去，上游kafka肯定会延迟越来越大的，可以在sink里多打印下错误，或者设置写入超时时间，问题应该在写入
- 2023-10-17 14:14cjpp老白的博客 kafka、ck、flink等实时组件的热门问题
- 2016-10-25 09:13回答 4 已采纳 明白了，offset已经指到最后了，然后获取不到数据就一直等待状态，我以为卡死，生产者发送几个数据进去就行了
- 2021-07-04 21:35Shockang的博客 我们都知道，消息积压的直接原因，一定是系统中的某个部分出现了性能问题，来不及处理上游发送的消息，才会导致消息积压。 所以，我们先来分析下，在使用消息队列时，如何来优化代码的性能，避免出现消息积压。 然后...
- 2024-06-28 00:40AI天才研究院的博客 而在Flink的Batch SQL任务中,经常会遇到Backpressured的问题,导致任务运行缓慢甚至失败。因此,深入理解Backpressured的原理,并能够在实践中加以应用,对于保证Flink Batch SQL任务的稳定性和效率至关重要。
- 没有解决我的问题, 去提问
问题事件
系统已结题
11月5日
创建了问题
10月28日
悬赏问题
- ¥15 求Houdini使用行家，付费。价格面议。
- ¥15 AttributeError: 'EasyDict' object has no attribute 'BACKUP_DB_INFO'
- ¥15 前端高拍仪调用问题报错
- ¥15 想用octave解决这个数学问题
- ¥15 Centos新建的临时ip无法上网，如何解决？
- ¥15 海康威视如何实现客户端软件对设备语音请求的处理。
- ¥15 支付宝h5参数如何实现跳转
- ¥15 MATLAB代码补全插值
- ¥15 Typegoose 中如何使用 arrayFilters 筛选并更新深度嵌套的子文档数组信息
- ¥15 CF1927D 求Hack