本文整理了Java中com.ucar.datalink.common.zookeeper.ZkConfig.<init>()方法的一些代码示例，展示了ZkConfig.<init>()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZkConfig.<init>()方法的具体详情如下：
包路径：com.ucar.datalink.common.zookeeper.ZkConfig
类名称：ZkConfig
方法名：<init>

ZkConfig.<init>介绍

暂无

代码示例

代码示例来源：origin: ucarGroup/DataLink

DLinkZkUtils.init(new ZkConfig(
    config.getString(WorkerConfig.ZK_SERVER_CONFIG),
    config.getInt(WorkerConfig.ZK_SESSION_TIMEOUT_MS_CONFIG),

代码示例来源：origin: ucarGroup/DataLink

private ReplicationConfig buidReplicationConfig(HBaseReaderParameter readerParameter) {
    ReplicationConfig config = new ReplicationConfig();
    config.setHbaseName("hbase-4-datalink");
    config.setZnodeParent(readerParameter.getReplZnodeParent());
    ZkMediaSrcParameter zkMediaSrcParameter = DataLinkFactory.getObject(MediaSourceService.class).
        getById(readerParameter.getReplZkMediaSourceId()).getParameterObj();
    config.setZkConfig(new ZkConfig(zkMediaSrcParameter.getServers(), 6000, 60000));
    return config;
  }
}

代码示例来源：origin: ucarGroup/DataLink

public void init(Properties props) {
  this.config = ManagerConfig.fromProps(props, true);
  this.zkUtils = DLinkZkUtils.init(new ZkConfig(config.getZkServer(), config.getZkSessionTimeoutMs(), config.getZkConnectionTimeoutMs()), config.getZkRoot());
  this.serverStatusMonitor = new ServerStatusMonitor(config, zkUtils);
  this.serverStatusMonitor.setListener(new ServerStatusListener() {
    @Override
    public void onActiveChange() {
      //只要发生Manager-Active-Change，不管本机是否是新的Manager，都把Group信息清除
      groupCoordinator.clearGroupMetaInfo();
      scheduleServer.onActiveChange();
    }
  });
  this.groupCoordinator = new GroupCoordinator(config, zkUtils, serverStatusMonitor);
  this.nettyServer = new NettyServer(this.config, this.groupCoordinator);
  this.jettyServer = new JettyServer(config);
  this.monitorManager = new MonitorManager();
  this.scheduleServer = new ScheduleServer(serverStatusMonitor);
  logger.info("ServerContainer is initialized.");
}