transferSetting( props, "security.protocol", "SASL_PLAINTEXT");
transferSetting( props, "sasl.mechanism", "PLAIN");
transferSetting( props, "bootstrap.servers",kafkaConnUrl);
transferSetting( props, "security.protocol", "SASL_PLAINTEXT");
transferSetting( props, "sasl.mechanism", "PLAIN");
transferSetting( props, "bootstrap.servers",kafkaConnUrl);