diff --git a/pulsar-broker-common/src/main/java/org/apache/pulsar/bookie/rackawareness/BookieRackAffinityMapping.java b/pulsar-broker-common/src/main/java/org/apache/pulsar/bookie/rackawareness/BookieRackAffinityMapping.java index 8790e0ad15708..9e5b9e71f623e 100644 --- a/pulsar-broker-common/src/main/java/org/apache/pulsar/bookie/rackawareness/BookieRackAffinityMapping.java +++ b/pulsar-broker-common/src/main/java/org/apache/pulsar/bookie/rackawareness/BookieRackAffinityMapping.java @@ -18,7 +18,6 @@ */ package org.apache.pulsar.bookie.rackawareness; -import com.google.api.client.util.Strings; import java.net.InetAddress; import java.util.ArrayList; import java.util.Collections; @@ -35,6 +34,7 @@ import org.apache.bookkeeper.net.BookieSocketAddress; import org.apache.bookkeeper.proto.BookieAddressResolver; import org.apache.commons.configuration.Configuration; +import org.apache.commons.lang.StringUtils; import org.apache.pulsar.common.policies.data.BookieInfo; import org.apache.pulsar.common.policies.data.BookiesRackConfiguration; import org.apache.pulsar.metadata.api.MetadataCache; @@ -161,7 +161,7 @@ private String getRack(String bookieAddress) { } if (bi != null - && !Strings.isNullOrEmpty(bi.getRack()) + && StringUtils.isNotEmpty(bi.getRack()) && !bi.getRack().trim().equals("/")) { String rack = bi.getRack(); if (!rack.startsWith("/")) {