• R
    support use `BitSet` generate the `BatchMessageAcker` (#7909) · 81202e14
    ran 提交于
    Motivation
    Currently, we have to know the batchSize to generate BatchMessageAcker. If we could get the batch index ack bitSet from Broker we could generate the BatchMessageAcker by the bitSet, this is useful for consuming transaction messages, we don't need to change the protocol to get the total message number of one transaction.
    
    Modifications
    Add a new static method to generate the BatchMessageAcker by BitSet.
    81202e14
ConsumerImpl.java 104.7 KB