diff --git a/d2/src/main/java/com/linkedin/d2/balancer/servers/ZooKeeperAnnouncer.java b/d2/src/main/java/com/linkedin/d2/balancer/servers/ZooKeeperAnnouncer.java index e29863651..51aa0991b 100644 --- a/d2/src/main/java/com/linkedin/d2/balancer/servers/ZooKeeperAnnouncer.java +++ b/d2/src/main/java/com/linkedin/d2/balancer/servers/ZooKeeperAnnouncer.java @@ -724,6 +724,10 @@ public void setEventEmitter(ServiceDiscoveryEventEmitter emitter) { @Override public void emitSDStatusActiveUpdateIntentAndWriteEvents(String cluster, boolean isMarkUp, boolean succeeded, long startAt) { + if (_server instanceof ZooKeeperServer) + { + return; + } if (_eventEmitter == null) { _log.info("Service discovery event emitter in ZookeeperAnnouncer is null. Skipping emitting events."); return;