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

转载 作者：知者 更新时间：2024-03-13 13:23:22 28 4

@Override
public TopicRepository provide() {
  return new ZookeeperTopicRepository(zookeeper, mapper, paths, groupRepository);
}

@Bean
TopicRepository topicRepository() {
  return new ZookeeperTopicRepository(storageZookeeper(), objectMapper, zookeeperPaths(), groupRepository());
}

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);
  }
}

28 4 0

• android - 使用 React Native 读取 NFC 标签类型 "android.nfc.tech.NfcV"和 "android.nfc.tech.NdefFormatable"

  我正在尝试使用 NFC 从血糖仪读取数据，目前在 Android 上，还没有尝试过 iOS(没有带 NFC 的手机)。 我正在使用 react-native-nfc-manager 作为库和它附带的示

• c - 是否可以在HI-TECH C中为PIC12 MCU创建多线程程序

  我的 friend 要我帮助他为PIC12 MCU编写一个小程序。我们想要 当输入电压在2秒钟内小于1.9V时，程序停止运行。 当输入电压超过2.5V时，程序将立即作出 react 。 我尝试通过阅读

• Android NFC - 问题

  我想在 Android 上编写我的第一个 NFC 应用程序。为此，我使用 android 开发人员链接:http://developer.android.com/guide/topics/nfc/in

• deployment - 无法使用Windows 10 Mobile Tech Preview将通用应用程序部署到手机

  我有一个开发人员已将解锁 Lumia 635 昨天更新为Windows 10 Mobile Technical Preview(操作系统版本: 10.0.12562.84 )。 在Visual Stu

• javascript - Video.js this.tech 未定义 firefox

  我正在尝试使用 BigVideo.js，它在 Chrome 和 Safari 中运行良好，但在 Firefox 中显示错误“this.tech is undefined”导致视频无法运行。有没有人以前

• javascript - 无法摆脱 this.tech.isReady is null or not an object

  我在使用 Video.JS 脚本(结合 BigVideo.js)时遇到一点问题 第 2511 行:this.tech.isReady 为空或不是对象 以下情况发生在 IE7-8 和 Firefox 1

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

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

• pl.allegro.tech.hermes.common.broker.ZookeeperBrokerStorage类的使用及代码示例

  本文整理了Java中pl.allegro.tech.hermes.common.broker.ZookeeperBrokerStorage类的一些代码示例，展示了ZookeeperBrokerStor

• 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

• elasticsearch - Elasticsearch-通过大写字母将术语标记化，例如 “TheStarTech” => [The，Star，Tech]

  Elasticsearch是否支持tokenizer来按大写字符对术语进行标记，例如:将TheStarTech标记为术语[The, Star, Tech]。 Pattern tokenizer似乎有帮

• pl.allegro.tech.hermes.test.helper.zookeeper.ZookeeperWaiter类的使用及代码示例

  本文整理了Java中pl.allegro.tech.hermes.test.helper.zookeeper.ZookeeperWaiter类的一些代码示例，展示了ZookeeperWaiter类的具

• pl.allegro.tech.hermes.common.admin.zookeeper.ZookeeperAdminCache类的使用及代码示例

  本文整理了Java中pl.allegro.tech.hermes.common.admin.zookeeper.ZookeeperAdminCache类的一些代码示例，展示了ZookeeperAdmi

• pl.allegro.tech.hermes.common.message.undelivered.ZookeeperUndeliveredMessageLog类的使用及代码示例

  本文整理了Java中pl.allegro.tech.hermes.common.message.undelivered.ZookeeperUndeliveredMessageLog类的一些代码示例，展

• laravel - 如何修复 "Table ' database.teches' does not exist” 错误？

  不知道为什么 migrate 正在寻找 'teches' 而不是真正的表名 'techs'？ 文件:TechsTableSeeder.php class TechsTableSeeder extend

• c - 这段代码在计算机内部是如何运行的？ P.S - 我是 b.tech 的一年级学生

  这个问题在这里已经有了答案: C/C++: Pointer Arithmetic (7 个答案) Why does int pointer '++' increment by 4 rather th

• wordpress - 我在我的网站 roundabout tech.com 上完成了 ssl。但是

  我在我的网站 roundabouttech.com 上做了 ssl。但问题是当我输入完整的“https://roundabouttech.com”时，它会以 https 打开。但是当我只输入“roun

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

  本文整理了Java中pl.allegro.tech.hermes.infrastructure.zookeeper.ZookeeperPaths.consumersRateHistoryPath()方

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

  本文整理了Java中pl.allegro.tech.hermes.infrastructure.zookeeper.ZookeeperPaths.consumersMaxRatePath()方法的一些