9

kafka消费者内存一直上涨

 3 years ago
source link: https://www.oschina.net/question/4175317_2324548
Go to the source link to view the article. You can view the picture content, updated content and better typesetting reading experience. If the link is broken, please click the button below to view the snapshot at that time.
neoserver,ios ssh client

kafka消费者内存一直上涨

Allen吴 发布于 11/29 15:14
阅读 462

spring-kafka    版本:1.3.4.RELEASE

消费者三台机器(每台内存不到8G),消费10几个topic,每个topic 3个分区

up-93ec31d50e558148f8ead17afc2000c40e4.png

为什么内存一直上升,不释放

以下是问题补充:

@Allen吴:消息大量堆积,消费者内存上升很快 (昨天 16:50)
纳兰清风
11/29 20:22

遇到这种情况难道不应该用jmap,jstat等工具进行分析么?

纳兰清风
昨天 17:46
回复 @Allen吴 : 多大流量啊,几台机器消费啊
纳兰清风
昨天 17:45
回复 @Allen吴 : 看是full gc还是young gc。young gc的话通过扩内存,扩展消费并行度,即多加几个机器一起消费来解决,full gc多说明有大对象,或内存泄漏,对了,KafkaConsumer不正常close会内存泄漏
Allen吴
前天 10:22
分析了,感觉是内存释放跟不上消费的速度
freezingsky
前天 10:05

大多数这种情况,都是自己业务代码有坑

Allen吴
前天 10:23
代码中也在不断的把一些大对象设置为null,还是稳步上升
却又让幽兰枯萎
前天 15:17

发的太猛了吧,我之前也遇到过,改了过期时间,设置得很小了,内存还是一直不断向上增长,后来放弃了这个,使用其他方案

却又让幽兰枯萎
今天 09:23
回复 @Allen吴 : 之前我做的是视频分析,一个解码一个进行推理,解码的速度基本上是每秒25帧左右,我把每一帧图像进行发布,推理这一端订阅接受,初步判断是接受不过来,解码停了二十几秒,这边还在接受,后来我没有尝试了,直接把解码和推理合并在一个项目里面了,另外有一个朋友尝试用redis好像据说也可以订阅发布,但是也有相同的问题,如果不是非要使用分布式没得必要使用像kafka和redis这样的东西
Allen吴
昨天 16:49
topic里都是业务线的一些异常日志,很多都是堆栈异常信息,是不是内存的释放赶不上消费的速度,是否有必要扩大分区,增加消费者,内存是否要加。还有你使用了其他什么方案。
Allen吴
今天 10:43

引用来自“纳兰清风”的评论

遇到这种情况难道不应该用jmap,jstat等工具进行分析么?

up-1f4a3c1d7519ac0dc96592fd018aab9617f.png

yongk
今天 11:25

一些push类型的MQ,都有prefetch特性,就是broker会多push一些msg给consumer,来提高吞吐量,这些在consumer端还没来得及处理的msg就占用consumer的内存。

但Kafka是pull类型的MQ,你看看会不会是类似的问题,kakfa为了提高吞吐量有没有相关设置。


Recommend

  • 47

    分享发现 - @exoticknight - 个人购买技术产品的经历分享,应该也算分享发现吧。虽然很糗,但是希望其他人不要重蹈覆辙还是发出来了。本来一直都很鄙视拼多多的。一直看到其被爆假货问题,售后问题,公司形象就是流氓。但毕竟这些都只是

  • 61
    • www.tuicool.com 5 years ago
    • Cache

    Kafka -- 多线程消费者

    Kafka Java Consumer从Kafka 0.10.1.0开始,KafkaConsumer变成了 双线程 设计,即 用户主线程 和 心跳线程 用户主线程:启动Consumer应用程序main方法的那个线程

  • 76
    • www.tuicool.com 5 years ago
    • Cache

    Kafka -- Java消费者管理TCP连接

    消费者会为每个要消费的分区创建与该分区 领导者副本 所在Broker的Socket连接 假设消费者要消费5个分区的数据,这5个分区各自的领导者副本分布在4台Broker上 那么消费者在消费时会创建与...

  • 9
    • objcoding.com 4 years ago
    • Cache

    Kafka 独立消费者

    Kafka 独立消费者 以前我们讨论的消费组,都是 group 的形式,group 可以自动地帮助消费者分配分区,且在发生异常时,还能自定地进行重平衡(Rebalance)。正常来说,group 帮助用户实现自动监听分区消费,但是在用户需要指定...

  • 10

    SpringBoot使用Testcontainers+Avro消息测试Kafka消费者您有一个 Spring Boot 微服务来管理用户数据。该微服务侦听来自 Kafka 的传入事件(例如用户创建、更新或删除),将它们转换为您自己的业务对象,将它们写入 PostgreSQL 数据库并通过 REST 接口将它们提供...

  • 9
    • www.tony-bro.com 3 years ago
    • Cache

    Kafka消费者消息拉取机制

    Kafka消费者消息拉取机制工作中有对Kafka重度使用的项目,其实很早就想写这一篇,但是当时也看到过一些类似的文章以及有一些其他的分享内容,所以一直拖到现在。对Kafka的使用聚焦在消费端,所以详细聊一下Kafka consumer消费过程中是如何拉取数据的。...

  • 10
    • ivalue2333.github.io 3 years ago
    • Cache

    消息队列之kafka 消费者的Offset管理

    消息队列之kafka 消费者的Offset管理 发表于 2021-01-21 ...

  • 3
    • zhangslob.github.io 3 years ago
    • Cache

    Kafka 消费者 Java 实现

    这是崔斯特的第一百一十三篇原创文章 努力、奋斗 (๑• . •๑) 应用程序使用 KafkaConsumer向 Kafka 订阅 Topic 接收消息,首先理解 Kafka 中消费者(consumer)和消费者组(consumer group)的概念和特性。 KafkaConsume...

  • 10
    • www.cnblogs.com 3 years ago
    • Cache

    Kafka 消费者解析 - 下半夜的风

    一、消费者相关概念 1.1 消费组&消费者 消费者: 消费者从订阅的主题消费消息,消费消息的偏移量保存在Kafka的名字是__consumer_offsets的主题中

  • 5

    英伟达RTX 4060 Ti 16GB版本备受争议,售价上涨却未能吸引消费者

About Joyk


Aggregate valuable and interesting links.
Joyk means Joy of geeK