@Override
    public MessageProducer createProducer() throws TubeClientException {
        this.brokerRcvQltyStats.startBrokerStatistic();
        try {
            this.producerManager.start();
        } catch (Throwable e) {
            if (e instanceof TubeClientException) {
                throw (TubeClientException) e;
            } else {
                throw new TubeClientException("Create Producer failure, ", e);
            }
        }
        return this.addClient(new SimpleMessageProducer(this, this.tubeClientConfig));
    }
Initial Session factory

@param clientFactory      the client factory
@param tubeClientConfig   the tube client configure
inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/factory/TubeBaseSessionFactory.java