it seems like three has a bug in ConsumerAggregator.java i think it should be `!ackSet.contains(msg.getMessageId())`