docs: @Override
      public void setReplicationActive(boolean active)
      {
          if (m_replicationActive.compareAndSet(!active, active)) {
  
              try {
                  JSONStringer js = new JSONStringer();
                  js.object();
                  js.keySymbolValuePair("active", m_replicationActive.get());
                  js.endObject();
  
                  getHostMessenger().getZK().setData(VoltZK.replicationconfig,
                                                     js.toString().getBytes("UTF-8"),
                                                     -1);
              } catch (Exception e) {
                  e.printStackTrace();
                  hostLog.error("Failed to write replication active state to ZK: " +
                                e.getMessage());
              }
  
              if (m_producerDRGateway != null) {
                  m_producerDRGateway.setActive(active);
              }
          }
      }