com.pinterest.secor.common.ZookeeperConnector.getCommittedOffsetGroupPath()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-13 11:12:54 25 4

private String getCommittedOffsetTopicPath(String topic) {
  return getCommittedOffsetGroupPath() + "/" + topic;
}

public List<String> getCommittedOffsetTopics() throws Exception {
  ZooKeeper zookeeper = mZookeeperClient.get();
  String offsetPath = getCommittedOffsetGroupPath();
  List<String> topics = zookeeper.getChildren(offsetPath, false);
  LinkedList<String> result = new LinkedList<String>();
  for (String topicPath : topics) {
    String[] elements = topicPath.split("/");
    String topic = elements[elements.length - 1];
    result.add(topic);
  }
  return result;
}

protected void verify(String zookeeperPath, String expectedOffsetPath) {
    ZookeeperConnector zookeeperConnector = new ZookeeperConnector();
    PropertiesConfiguration properties = new PropertiesConfiguration();
    properties.setProperty("kafka.zookeeper.path", zookeeperPath);
    properties.setProperty("secor.kafka.group", "secor_cg");
    SecorConfig secorConfig = new SecorConfig(properties);
    zookeeperConnector.setConfig(secorConfig);
    Assert.assertEquals(expectedOffsetPath, zookeeperConnector.getCommittedOffsetGroupPath());
  }
}

25 4 0

• pinterest - 有没有办法让 Pinterest 识别背景图像？

  就像添加一类“data-pin-pin”而不是“data-pin-nopin”？ slider 中有图像，但它们都是背景图像，因此当前 pin 按钮不起作用。 谢谢! 最佳答案 Pinterest 无

• pinterest - 获取带有特殊字符的板的 Pinterest RSS feed

  通常，要获取 Pinterest 版 block 的 RSS 提要，只需将“.rss”添加到 URL 末尾即可。 例如，对于 http://www.pinterest.com/philchairez/

• pinterest - 如何从 Pinterest API 获取搜索提要

  我正在搜索 Pinterest 的提要移动应用程序 API。 我可以知道如何从 Pinterest 获取搜索提要吗？ API。 最佳答案 这里有文档 https://developers.pinter

• pinterest - 如何使 Pinterest Widget Builder 具有响应性？

  Pinterest Widget Builder允许灵活地创建小部件以放置在您的网站上。我在 this page 上加了一个，但您可以为小部件设置的宽度似乎有限制。例如，我将宽度设置为 1170，但它

• pinterest - 是否不推荐使用 Pinterest API 中的关键字搜索 pin？

  自今年年初(整整 7 个月!)以来，关于 Pinterest API 中的搜索功能出现了几个问题。 示例:我在这里得到与我们的 friend leonardo 相同的回复:Pinterest API

• pinterest - 设置 oEmbed 提供程序以在 Pinterest 上嵌入网站内容

  我们希望将网站设置为 oEmbed 提供商。 官方文档 ( http://oembed.com/ ) 说: Configuration for oEmbed is very simple. Provi

• pinterest - 使用 React Native 的 Masonry/Pinterest 列

  有没有办法在 React Native 中使用 flexbox 来实现 Masonry/Pinterest 风格的列？ 最佳答案 在 React Native 中，远程图像不会在加载时调整大小(参见“

• java - 使用 pinterest 应用程序打开 pinterest 链接(如果存在)- android

  我想知道是否有相应的方法可以打开 pinterest 链接，如果安装了 pinterest 应用程序，或者如果它不在 Facebook 等设备中，则使用浏览器。对于 Facebook，我使用以下代码

• ios - 如何使用带有 Pinterest.sharextension 的 UIActivityViewController 设置 Pinterest sourceURL 和描述

  对于 iOS 8，Pinterest 有一个共享扩展。如何设置图片来源网址和描述属性？我正在使用 UIActivityViewController。我是否使用 UIImage、NSURL 用于 sou

• ios - 重新创建 Instagram/Pinterest 个人资料 - 如何在 swift 中重新创建 instagram/pinterest 个人资料？

  目前，我正在尝试重新创建类似 Instagram/Pinterest iOS 个人资料页面的内容，您可以在具有不同数据和布局的部分之间滑动，同时标题不会水平滚动，而是与每个部分垂直滚动。与当前 Ins

• Pinterest 生成的代币生命周期

  在页面 https://developers.pinterest.com/tools/access_token/您可以生成访问 token 。有谁知道那个 token 的生命周期是多少？它会在固定时间

• Pinterest 授权失败

  我们的 prod pinterest 应用程序有问题。 获得 token 后: "{"access_token": "AabcYgRUKiaBI45HYM72teXO6fZaFQoEhVxkxaREo

• api - Pinterest 板列表

  我正在寻找一种从给定用户名获取板名称列表的方法。我知道 pinterest 已经为给定用户的所有 pin 和给定 pinboard 的所有 pin 提供了 rss。 来自给定用户的所有 Pin 图:p

• authentication - Pinterest 中的身份验证代码端点是什么？

  这个文档很清楚:http://developers.pinterest.com/api_docs/oauth_code_exchange/ 我需要 code用访问 token 交换它。但是访问此代码的

• django - Pinterest API板分页

  任何人都可以对(未受过教育的)猜测如何使用未发布的Pinterest API进行分页吗？ 例如，此链接:https://api.pinterest.com/v3/pidgets/boards/grai

• pinterest - 如何获取Pinterest的OAuth访问 token ？

  我正在通过使用此url访问Pinterest API以获取用户信息，但是我找不到如何为Pinterest生成访问 token 的方法。 根据这个blog post，它说 Pinterest uses

• Pinterest API 停止工作

  关闭。这个问题是not reproducible or was caused by typos .它目前不接受答案。 想改善这个问题吗？更新问题，使其成为 on-topic对于堆栈溢出。 4年前关闭。

• javascript - Pinterest 无法获取图像

  尝试实现“固定它”按钮，但它会为每张图片返回以下问题。我们在整个网站上使用 SSL，我想知道这是否相关。 有什么想法吗？ {"route_pattern": "^/resource/:name/:me

• pinterest - Pin It 按钮不显示计数

  我集成了“Pin It”按钮以在 pinterest.com 上分享我的产品图片。但它不会在我网站上的 pin it 按钮前显示 pin 计数。我写了下面的代码。 这是我网站上的固定按钮 &这个

• javascript - Pinterest 板仅在页面重新加载时有效

  我有一个 AngularJS 应用程序，它是一个单页应用程序。在每个单独的页面上都会加载 Pinterest 板，这是通过 Pinterest 的小部件构建器完成的: This can be foun