@Override
        public void onException(Throwable e) {
            totalSentCnt.incrementAndGet();
            logger.error("Send message error!", e);
        }
Produce messages through multi-session factory instances.

@param args   Startup parameter array, including the following parts:
              The 1st parameter masterServers is the master address(es) to connect to,
                      format is master1_ip:port[,master2_ip:port];
              The 2nd parameter pubTopicAndFilterItems is the topic(s) (and filter condition set) to publish to,
                      format is topic_1[[:filterCond_1.1[;filterCond_1.2]][,topic_2]];
              The 3rd parameter msgCount is the message amount that needs to be sent;
              The 4th parameter pkgSize is the message's body size that needs to be sent;
              The 5th parameter clientCount is the amount of producer;
              The 6th parameter sessionFactoryCnt is the amount of session factory.
inlong-tubemq/tubemq-example/src/main/java/org/apache/inlong/tubemq/example/MAMessageProducerExample.java