wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/KafkaTopicSink.java [160:177]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public static Properties loadConfig(String propertiesFilePath) {
        // wayang-kafka-defaults.properties
        Properties props = new Properties();

        logger.info( "> use properties file in path: " + propertiesFilePath + " for Kafka client configuration.");

        if ( propertiesFilePath == null ) {
            return getDefaultProperties();
        }
        else {
            try (InputStream input = new FileInputStream(propertiesFilePath)) {
                props.load(input);
            } catch (IOException ex) {
                ex.printStackTrace();
            }
            return props;
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/KafkaTopicSource.java [139:156]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public static Properties loadConfig(String propertiesFilePath) {
        // wayang-kafka-defaults.properties
        Properties props = new Properties();

        logger.info( "> use properties file in path: " + propertiesFilePath + " for Kafka client configuration.");

        if ( propertiesFilePath == null ) {
            return getDefaultProperties();
        }
        else {
            try (InputStream input = new FileInputStream(propertiesFilePath)) {
                props.load(input);
            } catch (IOException ex) {
                ex.printStackTrace();
            }
            return props;
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -