public Map<MessageQueue, TopicOffset> getOffsetTable() {
        return offsetTable;
    }
@Test
    public void testGetOffsetTable() throws Exception {
        validateTopicStatsTable(topicStatsTable);
    }