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

ZookeeperPaths.<init>介绍

暂无

代码示例

代码示例来源：origin: allegro/hermes

@Override
public ZookeeperPaths provide() {
  return new ZookeeperPaths(config.getStringProperty(Configs.ZOOKEEPER_ROOT));
}

代码示例来源：origin: allegro/hermes

@Bean
ZookeeperPaths zookeeperPaths() {
  return new ZookeeperPaths(storageProperties.getPathPrefix());
}

代码示例来源：origin: allegro/hermes

private static ConsumerNodesRegistry createConsumersRegistry(ConfigFactory configs, CuratorFramework curator, Clock clock) {
  ThreadFactory threadFactory = new ThreadFactoryBuilder()
      .setNameFormat("ConsumerRegistryExecutor-%d").build();
  return new ConsumerNodesRegistry(curator,
      newSingleThreadExecutor(threadFactory),
      new ZookeeperPaths(configs.getStringProperty(Configs.ZOOKEEPER_ROOT)).consumersRegistryPath(configs.getStringProperty(Configs.KAFKA_CLUSTER_NAME)),
      configs.getStringProperty(Configs.CONSUMER_WORKLOAD_NODE_ID),
      configs.getIntProperty(CONSUMER_WORKLOAD_DEAD_AFTER_SECONDS),
      clock);
}

代码示例来源：origin: pl.allegro.tech.hermes/hermes-consumers

private static ConsumerNodesRegistry createConsumersRegistry(ConfigFactory configs, CuratorFramework curator, Clock clock) {
  ThreadFactory threadFactory = new ThreadFactoryBuilder()
      .setNameFormat("ConsumerRegistryExecutor-%d").build();
  return new ConsumerNodesRegistry(curator,
      newSingleThreadExecutor(threadFactory),
      new ZookeeperPaths(configs.getStringProperty(Configs.ZOOKEEPER_ROOT)).consumersRegistryPath(configs.getStringProperty(Configs.KAFKA_CLUSTER_NAME)),
      configs.getStringProperty(Configs.CONSUMER_WORKLOAD_NODE_ID),
      configs.getIntProperty(CONSUMER_WORKLOAD_DEAD_AFTER_SECONDS),
      clock);
}

代码示例来源：origin: allegro/hermes

@Override
public SubscriptionAssignmentRegistry provide() {
  ZookeeperPaths paths = new ZookeeperPaths(configFactory.getStringProperty(Configs.ZOOKEEPER_ROOT));
  String cluster = configFactory.getStringProperty(KAFKA_CLUSTER_NAME);
  String consumersRuntimePath = paths.consumersRuntimePath(cluster);
  return new SubscriptionAssignmentRegistry(
      curatorClient,
      subscriptionAssignmentCache,
      new SubscriptionAssignmentPathSerializer(consumersRuntimePath, AUTO_ASSIGNED_MARKER)
  );
}

代码示例来源：origin: pl.allegro.tech.hermes/hermes-consumers

@Override
public SubscriptionAssignmentRegistry provide() {
  ZookeeperPaths paths = new ZookeeperPaths(configFactory.getStringProperty(Configs.ZOOKEEPER_ROOT));
  String cluster = configFactory.getStringProperty(KAFKA_CLUSTER_NAME);
  String consumersRuntimePath = paths.consumersRuntimePath(cluster);
  return new SubscriptionAssignmentRegistry(
      curatorClient,
      subscriptionAssignmentCache,
      new SubscriptionAssignmentPathSerializer(consumersRuntimePath, AUTO_ASSIGNED_MARKER)
  );
}

代码示例来源：origin: allegro/hermes

ConsumerTestRuntimeEnvironment(Supplier<CuratorFramework> curatorSupplier) {
  this.paths = new ZookeeperPaths("/hermes");
  this.curatorSupplier = curatorSupplier;
  this.curator = curatorSupplier.get();
  this.groupRepository = new ZookeeperGroupRepository(curator, objectMapper, paths);
  this.topicRepository = new ZookeeperTopicRepository(curator, objectMapper, paths, groupRepository);
  this.subscriptionRepository = new ZookeeperSubscriptionRepository(
      curator, objectMapper, paths, topicRepository
  );
  this.configFactory = new MutableConfigFactory()
      .overrideProperty(CONSUMER_WORKLOAD_REBALANCE_INTERVAL, 1)
      .overrideProperty(CONSUMER_WORKLOAD_CONSUMERS_PER_SUBSCRIPTION, 2);
  this.consumersRegistry = new ConsumerNodesRegistry(
      curator, executorService, paths.consumersRegistryPath(CLUSTER_NAME), "id",
      DEATH_OF_CONSUMER_AFTER_SECONDS, Clock.systemDefaultZone());
  this.metricsSupplier = () -> new HermesMetrics(new MetricRegistry(), new PathsCompiler("localhost"));
  try {
    consumersRegistry.start();
  } catch (Exception e) {
    throw new InternalProcessingException(e);
  }
}