@EventMeshSPI(eventMeshExtensionType = EventMeshExtensionType.JDBC_DATABASE_DIALECT)
public interface DatabaseDialectFactory {

    /**
     * Creates a database dialect based on the provided source configuration.
     *
     * @param config the source configuration to create a database dialect for
     * @return the created database dialect
     */
    DatabaseDialect createDatabaseDialect(SourceConfig config);

}

@EventMeshSPI(eventMeshExtensionType = EventMeshExtensionType.JDBC_CDC_ENGINE)
public interface CdcEngineFactory {

    /**
     * Determines whether the provided JDBC URL is compatible with the CDC engine
     *
     * @param url jdbc url, e.g. mysql: jdbc:mysql://localhost:3306/
     * @return
     */
    boolean acceptJdbcProtocol(String url);

    /**
     * Creates a new CDC engine
     *
     * @return cdc engine
     */
    CdcEngine createCdcEngine(SourceConfig config, DatabaseDialect databaseDialect);

}

mysql=org.apache.eventmesh.source.connector.jdbc.dialect.cdc.mysql.MysqlCdcEngineFactory

mysql=org.apache.eventmesh.source.connector.jdbc.dialect.mysql.MysqlDatabaseDialectFactory

@UtilityClass
public class JdbcAllFactoryLoader {

    /**
     * Returns a CdcEngineFactory for the given database name.
     * <p>Throws NullPointerException if databaseName is null.</p>
     * <p>Throws IllegalArgumentException if CdcEngineFactory is not supported for the given database name.</p>
     *
     * @param databaseName Name of the database for which CdcEngineFactory is required.
     * @return CdcEngineFactory for the given database name.
     */
    public static CdcEngineFactory getCdcEngineFactory(String databaseName) {
        checkNotNull(databaseName, "database name can not be null");
        CdcEngineFactory engineFactory = EventMeshExtensionFactory.getExtension(CdcEngineFactory.class, databaseName);
        return checkNotNull(engineFactory, "CdcEngineFactory: " + databaseName + " is not supported");
    }

    /**
     * Returns a DatabaseDialectFactory based on the specified database name.
     *
     * @param databaseName the name of the database
     * @return the DatabaseDialectFactory for the specified database name
     * @throws NullPointerException     if the database name is null
     * @throws IllegalArgumentException if the specified database name is not supported
     */
    public static DatabaseDialectFactory getDatabaseDialectFactory(String databaseName) {
        Objects.requireNonNull(databaseName, "database name can not be null");
        DatabaseDialectFactory databaseDialectFactory = EventMeshExtensionFactory.getExtension(DatabaseDialectFactory.class, databaseName);
        Objects.requireNonNull(databaseDialectFactory, "DatabaseDialectFactory: " + databaseName + " is not supported");
        return databaseDialectFactory;
    }
}

2023-06-17 21:53:26,101 INFO  [main] MetaInfExtensionClassLoader(MetaInfExtensionClassLoader.java:86) - load extension class success, extensionType: interface org.apache.eventmesh.source.connector.jdbc.dialect.DatabaseDialectFactory, extensionClass: class org.apache.eventmesh.source.connector.jdbc.dialect.mysql.MysqlDatabaseDialectFactory
2023-06-17 21:53:26,106 INFO  [main] EventMeshExtensionFactory(EventMeshExtensionFactory.java:92) - initialize extension instance success, extensionType: interface org.apache.eventmesh.source.connector.jdbc.dialect.DatabaseDialectFactory, extensionInstanceName: mysql
2023-06-17 21:53:26,616 INFO  [main] MysqlDatabaseDialect(MysqlDatabaseDialect.java:87) - Mysql Connection initialize Success,JDBC driver metadata:JdbcDriverMetaData(JdbcMajorVersion=4, jdbcMinorVersion=2, jdbcDriverName=MySQL Connector/J, databaseProductName=MySQL, databaseProductVersion=8.0.33)
Exception in thread "main" java.lang.ClassCastException: org.apache.eventmesh.source.connector.jdbc.dialect.mysql.MysqlDatabaseDialectFactory cannot be cast to org.apache.eventmesh.source.connector.jdbc.dialect.cdc.CdcEngineFactory
	at org.apache.eventmesh.source.connector.jdbc.JdbcAllFactoryLoader.getCdcEngineFactory(JdbcAllFactoryLoader.java:46)
	at org.apache.eventmesh.source.connector.jdbc.connector.JdbcSourceConnector.init(JdbcSourceConnector.java:91)
	at org.apache.eventmesh.openconnect.SourceWorker.<init>(SourceWorker.java:59)
	at org.apache.eventmesh.openconnect.Application.run(Application.java:55)
	at org.apache.eventmesh.source.connector.jdbc.JdbcSourceWorker.main(JdbcSourceWorker.java:26)