spring kafka 设置超时时间（session.timeout.ms和max.poll.interval.ms）防止出现rebalance

作者：你好赵伟 | 2024-06-19 01:34:57

踩

session.timeout.ms

kafka的好多配置，在spring-kafka中没有明确的配置对应，但是预留了一个properties属性，可以设置所有的kafka配置

spring.kafka.properties.session.timeout.ms=10000 // 单位：毫秒

spring.kafka.properties.max.poll.interval.ms=300000 // 单位：毫秒

kafka会有一个心跳线程来同步服务端，告诉服务端自己是正常可用的，默认是3秒发送一次心跳，超过session.timeout.ms（默认10秒）服务端没有收到心跳就会认为当前消费者失效。max.poll.interval.ms决定了获取消息后提交偏移量的最大时间，超过设定的时间（默认5分钟），服务端也会认为该消费者失效。

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/你好赵伟/article/detail/734915

spring kafka 设置超时时间（session.timeout.ms和max.poll.interval.ms） 防止出现rebalance

spring kafka 设置超时时间（session.timeout.ms和max.poll.interval.ms）防止出现rebalance