session.time.out: 10000
heartbeat.interval.ms: 3000
max.poll.interval.ms: 300000
session.time.out指定消费者连接至消息队列会话超时时间,如果在这个时间内没有收到心跳包表示会话已超时,默认时间为10秒;
heartbeat.interval.ms指定心跳包发送频率,即间隔多长时间发送一次心跳包,优化该值的设置可以减少Rebalance操作,默认时间为3秒;
max.poll.interval.ms单次poll()操作后可以执行的最长时间,或者poll()调用之间的最大延迟,如果在这个延迟时间之内未收到下一次poll()操作,将认为客户端已失败,从而触发Rebalance操作,默认时间为5分钟,tips: 该值设置不正确时可能无法消费延迟消息;
参考文献-Kafka Consumer Configurations
版权声明:本文为sgc1310715652原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。