代码之家  ›  专栏  ›  技术社区  ›  arahant

kafka consumer request.timeout.ms的含义

  •  0
  • arahant  · 技术社区  · 7 年前

    从…起 https://kafka.apache.org/11/documentation.html#consumerconfigs

    配置控制客户端等待请求响应的最长时间。如果在超时时间过去之前未收到响应,则客户端将在必要时重新发送请求,或者在重试次数用尽时使请求失败。

    我们在这里谈论的是什么样的请求/响应?

    1 回复  |  直到 7 年前
        1
  •  2
  •   Lior Chaga    7 年前

    这会影响请求,如来自消费者的轮询消息或涉及主题分区元数据的任何其他请求。

    如果超过个月未收到心跳信号,消费者将离开该组 session.timeout.ms ,或如果消费者未进行超过 max.poll.interval.ms .

    推荐文章