### Question:
ConsumeQueueManager { public ConsumeQueueWaterMark getMinAccumulated(String topic, int queueId) { TopicQueue tq = new TopicQueue(topic, queueId); if (!tqMaxAccumulated.containsKey(tq)) { ConsumeQueueWaterMark consumeQueueWaterMark = calculateMinAccumulated(topic, queueId); if (consumeQueueWaterMark != null) { tqMaxAccumulated.putIfAbsent(tq, consumeQueueWaterMark); LOG.debug("ConsumeQueueWaterMark is put first time : {}", consumeQueueWaterMark); } else { LOG.warn("[BUG]calculateMaxAccumulated returns null for {}-{}", topic, queueId); } } return tqMaxAccumulated.get(tq); } private  ConsumeQueueManager(); void scanUnsubscribedTopic(); DeFiBrokerController getBrokerController(); static ConsumeQueueManager onlyInstance(); void recordLastDeliverOffset(final String group, final String topic, final int queueId, final long offset); long queryDeliverOffset(final String group, final String topic, final int queueId); long getMaxQueueDepth(String topic); void setBrokerController(DeFiBrokerController brokerController); void load(); ConsumeQueueWaterMark getMinAccumulated(String topic, int queueId); ConsumeQueueWaterMark calculateMinAccumulated(String topic, int queueId); long queryOffset(final String group, final String topic, final int queueId); void resetOffsetOnClient(String consumerGroup, String topic, int queueId, long maxDepth, long maxOffset);  }### Answer:
@Test public void testGetMinAccumulated() throws Exception { clientChannelInfo = new ClientChannelInfo(channel, clientId, LanguageCode.JAVA, 100); ConsumerData consumerData = createConsumerData(group, topic); deFiBrokerController.getConsumerManager().registerConsumer( consumerData.getGroupName(), clientChannelInfo, consumerData.getConsumeType(), consumerData.getMessageModel(), consumerData.getConsumeFromWhere(), consumerData.getSubscriptionDataSet(), false); deFiBrokerController.getConsumerOffsetManager().commitOffset(clientId, group, topic, queueId, offSet); consumeQueueManager.setBrokerController(deFiBrokerController); when(messageStore.getMaxOffsetInQueue(topic, queueId)).thenReturn(1025L); ConsumeQueueWaterMark mark = consumeQueueManager.getMinAccumulated(topic, queueId); assertThat(mark).isNotNull(); assertThat(mark.getTopic()).isEqualTo(topic); assertThat(mark.getConsumerGroup()).isEqualTo(group); assertThat(mark.getAccumulated()).isEqualTo(1); }