HostInfo activeHost = metadata.activeHost();
log.debug("Local store for {}: {}, {}:{}", username, metadata.partition(), activeHost.host(), activeHost.port());
- if (activeHost.equals(this.hostInfo))
+ if (activeHost.equals(this.hostInfo) || activeHost.equals(HostInfo.unavailable()))
{
return Optional.empty();
}