Minor changes in getting controller information

confluentinc · Nov 19, 2018 · 927d03e · 927d03e
1 parent 1e5f2d6
commit 927d03e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/kafka-rest/src/main/java/io/confluent/kafkarest/ClusterInformationObserver.java b/kafka-rest/src/main/java/io/confluent/kafkarest/ClusterInformationObserver.java
@@ -32,7 +32,7 @@
  */
 public class ClusterInformationObserver {
 
-  private ZkUtils zkUtils;
+  private final ZkUtils zkUtils;
 
   public ClusterInformationObserver(ZkUtils zkUtils) {
     this.zkUtils = zkUtils;
@@ -52,7 +52,7 @@ public BrokerEntity getCurrentClusterController() {
       }
       return new BrokerEntity(brokerInfo.id(), result);
     } else {
-      return null;
+      return BrokerEntity.empty();
     }
   }