in src/main/java/org/apache/geode/kafka/GeodeContext.java [52:58]
public ClientCache connectClient(List<LocatorHostPort> locatorHostPortList,
String securityAuthInit, String securityUserName, String securityPassword,
boolean usesSecurity) {
clientCache = createClientCache(locatorHostPortList, "", "", securityAuthInit, securityUserName,
securityPassword, usesSecurity);
return clientCache;
}