@Override
                    public Thread newThread(Runnable r) {
                        Thread t = new Thread(r, new StringBuilder(256)
                                .append("Producer-Heartbeat-Thread-")
                                .append(producerId).toString());
                        t.setPriority(Thread.MAX_PRIORITY);
                        return t;
                    }
Initial a producer manager

@param sessionFactory         the session factory
@param tubeClientConfig       the client configure
@throws TubeClientException   the exception while creating object
inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/producer/ProducerManager.java