public OffsetStore getOffsetStore() {
        return offsetStore;
    }
@Test
    public void testGetOffsetStore() {
        assertEquals(offsetStore, defaultMQPushConsumerImpl.getOffsetStore());
    }