class ProducerManager {

    public void shutdown() {
        log.info("Stop producer manager");
        transientProducerScheduler.shutdown();
    }

    public  ProducerManager(final SchedulerDriver schedulerDriver, final CoordinatorRegistryCenter regCenter);

}