public Properties getCredentials()

in src/main/java/org/apache/geode/kafka/security/SystemPropertyAuthInit.java [26:32]


  public Properties getCredentials(Properties securityProps, DistributedMember server,
      boolean isPeer) throws AuthenticationFailedException {
    Properties extractedProperties = new Properties();
    extractedProperties.put("security-username", securityProps.get("security-username"));
    extractedProperties.put("security-password", securityProps.get("security-password"));
    return extractedProperties;
  }