spring kafka 设置超时时间（session.timeout.ms和max.poll.interval.ms） 防止出现rebalance
kafka的好多配置，在spring-kafka中没有明确的配置对应，但是预留了一个properties属性，可以设置所有的kafka配置spring.kafka.properties.session.timeout.ms=10000 毫秒spring.kafka.properties.max.poll.interval.ms=300000 毫秒kafka会有一个心跳线程来同步服务端，告诉服务端自
·
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分钟），服务端也会认为该消费者失效。
Kafka开源项目指南提供详尽教程，助开发者掌握其架构、配置和使用，实现高效数据流管理和实时处理。它高性能、可扩展，适合日志收集和实时数据处理，通过持久化保障数据安全，是企业大数据生态系统的核心。
更多推荐
4
0- 0
已为社区贡献1条内容
所有评论(0)