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;
}