spring-kafka的消费者提交机制

「爱情、让人受尽委屈。」 2022-11-05 00:51 214阅读 0赞

## AckMode ##

/**
    	 * The offset commit behavior enumeration.
    	 */
    	public enum AckMode {
    
    		/**
    		 * Commit after each record is processed by the listener.
    		 */
    		RECORD,
    
    		/**
    		 * Commit whatever has already been processed before the next poll.
    		 */
    		BATCH,
    
    		/**
    		 * Commit pending updates after
    		 * {@link ContainerProperties#setAckTime(long) ackTime} has elapsed.
    		 */
    		TIME,
    
    		/**
    		 * Commit pending updates after
    		 * {@link ContainerProperties#setAckCount(int) ackCount} has been
    		 * exceeded.
    		 */
    		COUNT,
    
    		/**
    		 * Commit pending updates after
    		 * {@link ContainerProperties#setAckCount(int) ackCount} has been
    		 * exceeded or after {@link ContainerProperties#setAckTime(long)
    		 * ackTime} has elapsed.
    		 */
    		COUNT_TIME,
    
    		/**
    		 * User takes responsibility for acks using an
    		 * {@link AcknowledgingMessageListener}.
    		 */
    		MANUAL,
    
    		/**
    		 * User takes responsibility for acks using an
    		 * {@link AcknowledgingMessageListener}. The consumer
    		 * immediately processes the commit.
    		 */
    		MANUAL_IMMEDIATE,
    
    	}

*  RECORD  
    每处理一条commit一次
 *  BATCH(`默认`)  
    每次poll的时候批量提交一次，频率取决于每次poll的调用频率
 *  TIME  
    每次间隔ackTime的时间去commit(`跟auto commit interval有什么区别呢？`)
 *  COUNT  
    累积达到ackCount次的ack去commit
 *  COUNT\_TIME  
    ackTime或ackCount哪个条件先满足，就commit
 *  MANUAL  
    listener负责ack，但是背后也是批量上去
 *  MANUAL\_IMMEDIATE  
    listner负责ack，每调用一次，就立即commit