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

ZookeeperPaths.consumersRateRuntimePath介绍

暂无

代码示例

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

public String consumersMaxRatePath(String cluster, SubscriptionName subscription, String consumerId) {
  return Joiner.on(URL_SEPARATOR).join(consumersRateRuntimePath(cluster), subscription, consumerId,
      MAX_RATE_PATH);
}

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

public String consumersRatePath(String cluster, SubscriptionName subscription, String consumerId) {
  return Joiner.on(URL_SEPARATOR).join(consumersRateRuntimePath(cluster), subscription, consumerId);
}

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

public String consumersRateHistoryPath(String cluster, SubscriptionName subscription, String consumerId) {
  return Joiner.on(URL_SEPARATOR).join(consumersRateRuntimePath(cluster), subscription, consumerId,
      MAX_RATE_HISTORY_PATH);
}

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

public String consumersRateSubscriptionPath(String cluster, SubscriptionName subscription) {
  return Joiner.on(URL_SEPARATOR).join(consumersRateRuntimePath(cluster), subscription);
}

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

@Inject
public MaxRateRegistry(ConfigFactory configFactory, CuratorFramework curator, ObjectMapper objectMapper, ZookeeperPaths zookeeperPaths,
            MaxRatePathSerializer pathSerializer, SubscriptionsCache subscriptionsCache) {
  this.curator = curator;
  this.objectMapper = objectMapper;
  this.zookeeperPaths = zookeeperPaths;
  this.pathSerializer = pathSerializer;
  this.subscriptionsCache = subscriptionsCache;
  this.cluster = configFactory.getStringProperty(Configs.KAFKA_CLUSTER_NAME);
  ThreadFactory cacheThreadFactory = new ThreadFactoryBuilder().setNameFormat("max-rate-registry-%d").build();
  this.cache = new HierarchicalCache(curator,
      Executors.newSingleThreadExecutor(cacheThreadFactory),
      zookeeperPaths.consumersRateRuntimePath(cluster), 3, Collections.emptyList()
  );
  handleContentUpdates();
  handleConsumerUpdates();
}

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

@Inject
public MaxRateRegistry(ConfigFactory configFactory, CuratorFramework curator, ObjectMapper objectMapper, ZookeeperPaths zookeeperPaths,
            MaxRatePathSerializer pathSerializer, SubscriptionsCache subscriptionsCache) {
  this.curator = curator;
  this.objectMapper = objectMapper;
  this.zookeeperPaths = zookeeperPaths;
  this.pathSerializer = pathSerializer;
  this.subscriptionsCache = subscriptionsCache;
  this.cluster = configFactory.getStringProperty(Configs.KAFKA_CLUSTER_NAME);
  ThreadFactory cacheThreadFactory = new ThreadFactoryBuilder().setNameFormat("max-rate-registry-%d").build();
  this.cache = new HierarchicalCache(curator,
      Executors.newSingleThreadExecutor(cacheThreadFactory),
      zookeeperPaths.consumersRateRuntimePath(cluster), 3, Collections.emptyList()
  );
  handleContentUpdates();
  handleConsumerUpdates();
}