private static void setImportInfo ( Catalog catalog , ImportType importType ) { if ( importType == null ) { return ; } List < String > streamList = new ArrayList <> ( ) ; List < ImportConfigurationType > kafkaConfigs = new ArrayList <> ( ) ; for ( ImportConfigurationType importConfiguration : importType . getConfiguration ( ) ) { boolean connectorEnabled = importConfiguration . isEnabled ( ) ; if ( ! connectorEnabled ) { continue ; } if ( importConfiguration . getType ( ) . equals ( ServerImportEnum . KAFKA ) ) { kafkaConfigs . add ( importConfiguration ) ; } if ( ! streamList . contains ( importConfiguration . getModule ( ) ) ) { streamList . add ( importConfiguration . getModule ( ) ) ; } buildImportProcessorConfiguration ( importConfiguration , true ) ; } validateKafkaConfig ( kafkaConfigs ) ; }
Set deployment time settings for import