@Override
    public void start() throws PulsarClientException {
        flow.initialize();
    }
@Test
    public void testStart() throws Exception {
        this.auth.start();
        verify(this.flow).initialize();
    }