@Deprecated
    public OffsetStore getOffsetStore() {
        return offsetStore;
    }
@Test
    public void testStart_OffsetShouldNotNUllAfterStart() {
        assertNotNull(pushConsumer.getOffsetStore());
    }