@Override
    public InLongTcpMsgSender genTcpSenderByClusterId(
            TcpMsgSenderConfig configure, ThreadFactory selfDefineFactory) throws ProxySdkException {
        if (!initialized.get()) {
            throw new ProxySdkException("Please initialize the factory first!");
        }
        return baseMsgSenderFactory.genTcpSenderByClusterId(configure, selfDefineFactory);
    }
Singleton Message Sender Factory

Used to define the singleton sender factory
inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/MsgSenderSingleFactory.java