前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >ckafka这个消费者参数配置后, 为什么Kafka rebalance时间好长, 超过一个小时 还没有完成

ckafka这个消费者参数配置后, 为什么Kafka rebalance时间好长, 超过一个小时 还没有完成

原创
作者头像
沐榕樰
发布2024-07-04 20:13:43
610
发布2024-07-04 20:13:43
举报
文章被收录于专栏:发哥说消息队列

ckafka这个消费者参数配置后, 为什么Kafka rebalance时间好长, 超过一个小时 还没有完成

问题描述: 这个消费者参数配置后, 为什么Kafka rebalance时间好长, 超过一个小时 还没有完成 KafkaConsumer(bootstrap_servers=_hosts, auto_offset_reset=_offset_mode, group_id=_group_id, enable_auto_commit=_auto_commit, api_version=(0, 9), max_poll_interval_ms=300000, max_poll_records=1, session_timeout_ms=300000, request_timeout_ms=310000, connections_max_idle_ms=320000, heartbeat_interval_ms=300000, consumer_timeout_ms=1800000)

解决方案:使用 Kafka 消费分组机制时,消费者发送心跳的间隔。heartbeat_interval_ms这个值必须小于 session.timeout.ms,一般小于它的三分之一

结果:修改heartbeat_interval_ms 后 relbance 时间快多了

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

原创声明:本文系作者授权腾讯云开发者社区发表,未经许可,不得转载。

如有侵权,请联系 cloudcommunity@tencent.com 删除。

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档