@Override
    public PushMessageConsumer createPushConsumer(final ConsumerConfig consumerConfig)
            throws TubeClientException {
        if (!tubeClientConfig.getMasterInfo().equals(consumerConfig.getMasterInfo())) {
            throw new TubeClientException(new StringBuilder(512)
                    .append("consumerConfig's masterInfo not equal!")
                    .append(" SessionFactory's masterInfo is ")
                    .append(tubeClientConfig.getMasterInfo().getMasterClusterStr())
                    .append(", consumerConfig's masterInfo is ")
                    .append(consumerConfig.getMasterInfo().getMasterClusterStr()).toString());
        }
        return this.addClient(new SimplePushMessageConsumer(this, consumerConfig));
    }
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