pl.allegro.tech.hermes.infrastructure.zookeeper.ZookeeperPaths.consumersRatePath()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-14 12:45:31 27 4

private void removeConsumerEntries(SubscriptionName subscriptionName, String consumerId) {
  try {
    curator.delete().deletingChildrenIfNeeded()
        .forPath(zookeeperPaths.consumersRatePath(cluster, subscriptionName, consumerId));
  } catch (KeeperException.NoNodeException e) {
    // ignore
  } catch (Exception e) {
    throw new InternalProcessingException(e);
  }
}

private void removeConsumerEntries(SubscriptionName subscriptionName, String consumerId) {
  try {
    curator.delete().deletingChildrenIfNeeded()
        .forPath(zookeeperPaths.consumersRatePath(cluster, subscriptionName, consumerId));
  } catch (KeeperException.NoNodeException e) {
    // ignore
  } catch (Exception e) {
    throw new InternalProcessingException(e);
  }
}

@Test
public void shouldRemoveInactiveConsumerEntries() throws Exception {
  // given
  ConsumerInstance consumer1 = consumer("consumer1");
  ConsumerInstance consumer2 = consumer("consumer2");
  maxRateRegistry.ensureCorrectAssignments(subscription, Sets.newHashSet("consumer1", "consumer2"));
  maxRateRegistry.update(subscription, ImmutableMap.of(
      "consumer1", new MaxRate(350.0),
      "consumer2", new MaxRate(0.5)
  ));
  wait.untilZookeeperPathIsCreated(
      zookeeperPaths.consumersMaxRatePath(cluster, consumer1.getSubscription(), consumer1.getConsumerId()));
  wait.untilZookeeperPathIsCreated(
      zookeeperPaths.consumersMaxRatePath(cluster, consumer2.getSubscription(), consumer2.getConsumerId()));
  // when
  maxRateRegistry.ensureCorrectAssignments(subscription, Sets.newHashSet("consumer1", "consumer3"));
  wait.untilZookeeperPathNotExists(
      zookeeperPaths.consumersRatePath(cluster, consumer2.getSubscription(), consumer2.getConsumerId()));
  // then
  assertEquals(Optional.empty(), maxRateRegistry.getMaxRate(consumer2));
}

27 4 0

• oracle-cloud-infrastructure - 在 Oracle Cloud Infrastructure Compute 节点上打开端口 80

  关闭。这个问题不符合Stack Overflow guidelines .它目前不接受答案。 想改进这个问题？将问题更新为 on-topic对于堆栈溢出。 1年前关闭。 社区上个月审查了是否重新打开此

• infrastructure - 当您需要在公司中建立软件开发基础架构时，什么最重要？

  就目前而言，这个问题不适合我们的问答形式。我们希望答案得到事实、引用或专业知识的支持，但这个问题可能会引起辩论、争论、投票或扩展讨论。如果您觉得这个问题可以改进并可能重新打开，visit the he

• infrastructure - 即使有可靠的远程MTA，也可以使用本地MTA

  我与我们的开发团队进行了讨论，以在应用程序服务器上安装本地MTA，或者是否应该使用内部网络上的MTA服务器发送电子邮件。两种解决方案都各有利弊。 优点:发送电子邮件的程序可以将其传递到本地MTA，而不

• oracle-cloud-infrastructure - 从控制台中删除终止的实例需要多长时间？

  文档说( Terminating an Instance )，已终止的实例暂时保留在状态为已终止的实例列表中。 从控制台中删除终止的实例是否有任何特定的时间限制？ 最佳答案 终止 API 调用成功后停

• pointers - LLVM Compiler Infrastructure 中是否有一种方法可以将指针常量转换为不同类型的指针常量？

  我从一个全局变量的地址得到了一个 *TypeB 类型的常量指针，我需要将它转换为一个 *TypeA 类型的指针，其中 TypeB 不同于 TypeA 但也是有效的 TypeA。 例如 TypeA 可能

• kubernetes - 启用Istio的GKE群集无法与Google Service Infrastructure API可靠地通信

  我无法可靠地允许启用了istio的Google Kubernetes Engine集群通过extensible service proxy连接到Google Cloud Endpoints(服务管理A

• oracle-cloud-infrastructure - Oracle 云实例连接问题

  我对云没有经验。我在 Oracle Cloud 中创建了一个计算实例。但是，当我尝试使用公共(public) i/p 通过 ssh 访问它时，它显示“无法连接到主机端口 22:操作超时”。我已经为实例

• c# - 无法激活类型 'FluentMigrator.Infrastructure.DefaultEmbeddedResourceProvider

  我正在使用 FuentMigrator 和 FluentMigrator.Runner 3.1.3 我的迁移工作正常并针对数据库执行。但是当我尝试执行嵌入式资源 sql 时，我收到以下错误消息: 无法

• c# - 无法加载文件或程序集“Microsoft.Web.Infrastructure，

  我试图将我的网站上传到服务器。它在我的本地主机上运行良好，所以我将本地主机 wwwroot 文件夹中的所有内容上传到服务器并更改了连接字符串。 但是有这个错误: Exception informati

• python - AppRegistryNotReady : The translation infrastructure cannot be initialized

  当我尝试访问我的应用时，我收到以下错误。 AppRegistryNotReady: The translation infrastructure cannot be initialized befor

• ibm-cloud-infrastructure - 如何知道订购的 block 存储设备的id

  您好，我已经使用下单方法在软层上订购了 block 存储设备。我想知道订购设备的名称和 ID。怎么会知道呢。下订单方法不返回 id 或名称作为响应。我需要 id 才能在 softlayer 上调用一些

• oracle-cloud-infrastructure - 启动卷和 block 卷有什么区别？

  引导卷是指包含操作系统文件的磁盘卷吗？引导卷和块卷的定义是什么？ 最佳答案 是的，通常启动卷用作计算实例的操作系统磁盘，块卷用作数据存储，但启动卷也是一种块卷。 一些差异: 启动实例不需要块卷，但需要

• ios - 多点连接: Not discovering device over Wifi Infrastructure

  我在 Macbook Pro 上创建了一个网络(位于 WiFi 列表下方)，并且有 2 个 iOS 7(iPad 2 和 iPod Touch)设备加入到该网络。当我开始浏览设备时，我只是在 nati

• C# 需要访问 Microsoft Management Infrastructure 命名空间

  全部，我正在编写一个 Powershell cmdlet。让我的本地机器上的 cmdlet 一切正常。查看访问远程计算机所需的内容，似乎我需要在我的项目中引用 Microsoft.Management

• python - 领域驱动设计(DDD): A Domain or Infrastructure Concern

  我正在沉浸在 DDD 中，并且有一个关于什么属于该域以及什么是基础设施问题的问题。 描述域的简化示例: 应用程序中的上下文之一是关于允许用户检查网页以获取某些信息的便利功能。即.. “用户想要检查网页

• pl.allegro.tech.hermes.infrastructure.zookeeper.ZookeeperPaths类的使用及代码示例

  本文整理了Java中pl.allegro.tech.hermes.infrastructure.zookeeper.ZookeeperPaths类的一些代码示例，展示了ZookeeperPaths类的

• pl.allegro.tech.hermes.infrastructure.zookeeper.ZookeeperTopicRepository类的使用及代码示例

  本文整理了Java中pl.allegro.tech.hermes.infrastructure.zookeeper.ZookeeperTopicRepository类的一些代码示例，展示了Zookee

• pl.allegro.tech.hermes.infrastructure.zookeeper.ZookeeperSubscriptionRepository类的使用及代码示例

  本文整理了Java中pl.allegro.tech.hermes.infrastructure.zookeeper.ZookeeperSubscriptionRepository类的一些代码示例，展示

• pl.allegro.tech.hermes.infrastructure.zookeeper.ZookeeperGroupRepository类的使用及代码示例

  本文整理了Java中pl.allegro.tech.hermes.infrastructure.zookeeper.ZookeeperGroupRepository类的一些代码示例，展示了Zookee

• asp.net - Microsoft.Web.Infrastructure.dll 痛苦

  伙计们，我对添加对 Microsoft.Web.Infrastructure.dll 的引用感到非常痛苦，也许有人可以帮我解决这个问题。 我正在尝试添加对 Microsoft.Web.Infrastr