zoukankan      html  css  js  c++  java
  • kafka学习总结016 --- consumer配置参数session.timeout.ms和heartbeat.interval.ms

    前面说过了consumer心跳机制:consumer定期向coordinator发送心跳请求,以表明自己还在线;如果session.timeout.ms内未发送请求,coordinator认为其不可用,然后触发rebalance

    session.timeout.ms:coordinator感知consumer崩溃所需时间,默认10秒

    heartbeat.interval.ms:consumer发送心跳请求间隔,默认3秒

    示例:topic1有2个分区,3个副本;三个消费者属于同一个组,并订阅该topic;

    可以看到前两个消费者分别消费0号分区和1号分区,第三个消费者闲置;所以实际应用中,组内消费者的个数不要大于分区数,否则会造成资源浪费。

    把consumer3停掉,10秒后能够看到consumer1和consumer2,由于rebalance心跳失败,并且重新加入组

    使用建议:

    1、session.timeout.ms一定要大于heartbeat.interval.ms,否则消费者组会一直处于rebalance状态

    2、session.timeout.ms最好几倍于heartbeat.interval.ms;这是因为如果因为某一时间段的网络延迟导致coordinator未感知到心跳请求,session.timeout.ms和heartbeat.interval.ms接近的话,会导致consumer组rebalance过于频繁,影响消费性能

  • 相关阅读:
    UVA 11235 (游程编码+ST算法)
    CodeForces 359D (数论+二分+ST算法)
    线性动态规划
    AC自动机
    KMP
    字典树
    Treap和名次树
    线段树
    最小生成树
    【VS】使用vs2017自带的诊断工具(Diagnostic Tools)诊断程序的内存问题
  • 原文地址:https://www.cnblogs.com/sniffs/p/13204107.html
Copyright © 2011-2022 走看看