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