public void start() throws Throwable {
        if (nodeStatus.get() <= 0) {
            if (nodeStatus.compareAndSet(-1, 0)) {
                register2Master();
                logger.info("[Producer] Producer status from ready to running!");
            }
        }
    }
Start the producer manager.

@throws Throwable  the exception
inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/producer/ProducerManager.java