private MySQLBinlogSource createMysqlSource() {
        MySQLBinlogSource binlogSource = new MySQLBinlogSource();
        binlogSource.setDatabaseWhiteList("{db.name}");
        binlogSource.setHostname("{db.url}");
        binlogSource.setUser("{user}");
        binlogSource.setPassword("{password}");
        binlogSource.setSourceName("{mysql.source.name}");
        binlogSource.setAllMigration(true);
        return binlogSource;
    }
Test class for binlog to kafka.
inlong-manager/manager-client-examples/src/test/java/org/apache/inlong/manager/client/Binlog2KafkaExample.java