02
02/24
Kafka 消费者poll配置
消费者poll消息的细节与消费者心跳配置 长轮询poll消息 默认情况下,消费者⼀次会poll500条消息。 //⼀次poll最⼤拉取消息的条数,可以根据消费速度的快慢来设置 props.put(ConsumerConfig.MAX_POLL_RECORDS_CONFIG, 500); 意味着: 如果⼀次poll到500条,就直接执⾏for循环 如果这⼀次没有poll到500条。且时间在1秒内,那么⻓轮询继续poll,要么到500条,要么到1s 如果多次poll都没达到500条,且1秒时间到了,那么直接执⾏for循环 如果两次poll的间隔超过30s,集群会认为该消费者的消费能⼒过弱,该消费者被踢出...