org.apache.flink.streaming.connectors.kafka.testutils.ZooKeeperStringSerializer类的使用及代码示例-6ren

org.apache.flink.streaming.connectors.kafka.testutils.ZooKeeperStringSerializer类的使用及代码示例

转载作者：知者更新时间：2024-03-13 23:26:19

本文整理了Java中org.apache.flink.streaming.connectors.kafka.testutils.ZooKeeperStringSerializer类的一些代码示例，展示了ZooKeeperStringSerializer类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZooKeeperStringSerializer类的具体详情如下：
包路径：org.apache.flink.streaming.connectors.kafka.testutils.ZooKeeperStringSerializer
类名称：ZooKeeperStringSerializer

ZooKeeperStringSerializer介绍

[英]Simple ZooKeeper serializer for Strings.
[中]字符串的简单ZooKeeper序列化程序。

代码示例

代码示例来源：origin: apache/flink

public ZkUtils getZkUtils() {
  LOG.info("In getZKUtils:: zookeeperConnectionString = {}", zookeeperConnectionString);
  ZkClient creator = new ZkClient(zookeeperConnectionString, Integer.valueOf(standardProps.getProperty("zookeeper.session.timeout.ms")),
      Integer.valueOf(standardProps.getProperty("zookeeper.connection.timeout.ms")), new ZooKeeperStringSerializer());
  return ZkUtils.apply(creator, false);
}

代码示例来源：origin: apache/flink

public ZkUtils getZkUtils() {
  ZkClient creator = new ZkClient(zookeeperConnectionString, Integer.valueOf(standardProps.getProperty("zookeeper.session.timeout.ms")),
      Integer.valueOf(standardProps.getProperty("zookeeper.connection.timeout.ms")), new ZooKeeperStringSerializer());
  return ZkUtils.apply(creator, false);
}

代码示例来源：origin: apache/flink

public ZkUtils getZkUtils() {
  ZkClient creator = new ZkClient(zookeeperConnectionString, Integer.valueOf(standardProps.getProperty("zookeeper.session.timeout.ms")),
      Integer.valueOf(standardProps.getProperty("zookeeper.connection.timeout.ms")), new ZooKeeperStringSerializer());
  return ZkUtils.apply(creator, false);
}

代码示例来源：origin: apache/flink

@Override
public void deleteTestTopic(String topic) {
  ZkUtils zkUtils = getZkUtils();
  try {
    LOG.info("Deleting topic {}", topic);
    ZkClient zk = new ZkClient(zookeeperConnectionString, Integer.valueOf(standardProps.getProperty("zookeeper.session.timeout.ms")),
      Integer.valueOf(standardProps.getProperty("zookeeper.connection.timeout.ms")), new ZooKeeperStringSerializer());
    AdminUtils.deleteTopic(zkUtils, topic);
    zk.close();
  } finally {
    zkUtils.close();
  }
}

代码示例来源：origin: apache/flink

@Override
public void deleteTestTopic(String topic) {
  ZkUtils zkUtils = getZkUtils();
  try {
    LOG.info("Deleting topic {}", topic);
    ZkClient zk = new ZkClient(zookeeperConnectionString, Integer.valueOf(standardProps.getProperty("zookeeper.session.timeout.ms")),
      Integer.valueOf(standardProps.getProperty("zookeeper.connection.timeout.ms")), new ZooKeeperStringSerializer());
    AdminUtils.deleteTopic(zkUtils, topic);
    zk.close();
  } finally {
    zkUtils.close();
  }
}

代码示例来源：origin: apache/flink

@Override
public void deleteTestTopic(String topic) {
  ZkUtils zkUtils = getZkUtils();
  try {
    LOG.info("Deleting topic {}", topic);
    ZkClient zk = new ZkClient(zookeeperConnectionString, Integer.valueOf(standardProps.getProperty("zookeeper.session.timeout.ms")),
      Integer.valueOf(standardProps.getProperty("zookeeper.connection.timeout.ms")), new ZooKeeperStringSerializer());
    AdminUtils.deleteTopic(zkUtils, topic);
    zk.close();
  } finally {
    zkUtils.close();
  }
}

代码示例来源：origin: com.alibaba.blink/flink-connector-kafka-0.11

public ZkUtils getZkUtils() {
  ZkClient creator = new ZkClient(zookeeperConnectionString, Integer.valueOf(standardProps.getProperty("zookeeper.session.timeout.ms")),
      Integer.valueOf(standardProps.getProperty("zookeeper.connection.timeout.ms")), new ZooKeeperStringSerializer());
  return ZkUtils.apply(creator, false);
}

代码示例来源：origin: org.apache.flink/flink-connector-kafka-0.11

public ZkUtils getZkUtils() {
  ZkClient creator = new ZkClient(zookeeperConnectionString, Integer.valueOf(standardProps.getProperty("zookeeper.session.timeout.ms")),
      Integer.valueOf(standardProps.getProperty("zookeeper.connection.timeout.ms")), new ZooKeeperStringSerializer());
  return ZkUtils.apply(creator, false);
}

代码示例来源：origin: org.apache.flink/flink-connector-kafka-0.9_2.11

public ZkUtils getZkUtils() {
  LOG.info("In getZKUtils:: zookeeperConnectionString = {}", zookeeperConnectionString);
  ZkClient creator = new ZkClient(zookeeperConnectionString, Integer.valueOf(standardProps.getProperty("zookeeper.session.timeout.ms")),
      Integer.valueOf(standardProps.getProperty("zookeeper.connection.timeout.ms")), new ZooKeeperStringSerializer());
  return ZkUtils.apply(creator, false);
}

代码示例来源：origin: org.apache.flink/flink-connector-kafka-0.10_2.11

public ZkUtils getZkUtils() {
  ZkClient creator = new ZkClient(zookeeperConnectionString, Integer.valueOf(standardProps.getProperty("zookeeper.session.timeout.ms")),
      Integer.valueOf(standardProps.getProperty("zookeeper.connection.timeout.ms")), new ZooKeeperStringSerializer());
  return ZkUtils.apply(creator, false);
}

代码示例来源：origin: org.apache.flink/flink-connector-kafka-0.11_2.11

public ZkUtils getZkUtils() {
  ZkClient creator = new ZkClient(zookeeperConnectionString, Integer.valueOf(standardProps.getProperty("zookeeper.session.timeout.ms")),
      Integer.valueOf(standardProps.getProperty("zookeeper.connection.timeout.ms")), new ZooKeeperStringSerializer());
  return ZkUtils.apply(creator, false);
}

代码示例来源：origin: com.alibaba.blink/flink-connector-kafka-0.10

public ZkUtils getZkUtils() {
  ZkClient creator = new ZkClient(zookeeperConnectionString, Integer.valueOf(standardProps.getProperty("zookeeper.session.timeout.ms")),
      Integer.valueOf(standardProps.getProperty("zookeeper.connection.timeout.ms")), new ZooKeeperStringSerializer());
  return ZkUtils.apply(creator, false);
}

代码示例来源：origin: com.alibaba.blink/flink-connector-kafka-0.9

public ZkUtils getZkUtils() {
  LOG.info("In getZKUtils:: zookeeperConnectionString = {}", zookeeperConnectionString);
  ZkClient creator = new ZkClient(zookeeperConnectionString, Integer.valueOf(standardProps.getProperty("zookeeper.session.timeout.ms")),
      Integer.valueOf(standardProps.getProperty("zookeeper.connection.timeout.ms")), new ZooKeeperStringSerializer());
  return ZkUtils.apply(creator, false);
}

代码示例来源：origin: org.apache.flink/flink-connector-kafka-0.10

public ZkUtils getZkUtils() {
  ZkClient creator = new ZkClient(zookeeperConnectionString, Integer.valueOf(standardProps.getProperty("zookeeper.session.timeout.ms")),
      Integer.valueOf(standardProps.getProperty("zookeeper.connection.timeout.ms")), new ZooKeeperStringSerializer());
  return ZkUtils.apply(creator, false);
}

代码示例来源：origin: org.apache.flink/flink-connector-kafka-0.11

@Override
public void deleteTestTopic(String topic) {
  ZkUtils zkUtils = getZkUtils();
  try {
    LOG.info("Deleting topic {}", topic);
    ZkClient zk = new ZkClient(zookeeperConnectionString, Integer.valueOf(standardProps.getProperty("zookeeper.session.timeout.ms")),
      Integer.valueOf(standardProps.getProperty("zookeeper.connection.timeout.ms")), new ZooKeeperStringSerializer());
    AdminUtils.deleteTopic(zkUtils, topic);
    zk.close();
  } finally {
    zkUtils.close();
  }
}

代码示例来源：origin: com.alibaba.blink/flink-connector-kafka-0.10

@Override
public void deleteTestTopic(String topic) {
  ZkUtils zkUtils = getZkUtils();
  try {
    LOG.info("Deleting topic {}", topic);
    ZkClient zk = new ZkClient(zookeeperConnectionString, Integer.valueOf(standardProps.getProperty("zookeeper.session.timeout.ms")),
      Integer.valueOf(standardProps.getProperty("zookeeper.connection.timeout.ms")), new ZooKeeperStringSerializer());
    AdminUtils.deleteTopic(zkUtils, topic);
    zk.close();
  } finally {
    zkUtils.close();
  }
}

代码示例来源：origin: org.apache.flink/flink-connector-kafka-0.11_2.11

@Override
public void deleteTestTopic(String topic) {
  ZkUtils zkUtils = getZkUtils();
  try {
    LOG.info("Deleting topic {}", topic);
    ZkClient zk = new ZkClient(zookeeperConnectionString, Integer.valueOf(standardProps.getProperty("zookeeper.session.timeout.ms")),
      Integer.valueOf(standardProps.getProperty("zookeeper.connection.timeout.ms")), new ZooKeeperStringSerializer());
    AdminUtils.deleteTopic(zkUtils, topic);
    zk.close();
  } finally {
    zkUtils.close();
  }
}

代码示例来源：origin: com.alibaba.blink/flink-connector-kafka-0.9

@Override
public void deleteTestTopic(String topic) {
  ZkUtils zkUtils = getZkUtils();
  try {
    LOG.info("Deleting topic {}", topic);
    ZkClient zk = new ZkClient(zookeeperConnectionString, Integer.valueOf(standardProps.getProperty("zookeeper.session.timeout.ms")),
      Integer.valueOf(standardProps.getProperty("zookeeper.connection.timeout.ms")), new ZooKeeperStringSerializer());
    AdminUtils.deleteTopic(zkUtils, topic);
    zk.close();
  } finally {
    zkUtils.close();
  }
}

代码示例来源：origin: org.apache.flink/flink-connector-kafka-0.9_2.11

@Override
public void deleteTestTopic(String topic) {
  ZkUtils zkUtils = getZkUtils();
  try {
    LOG.info("Deleting topic {}", topic);
    ZkClient zk = new ZkClient(zookeeperConnectionString, Integer.valueOf(standardProps.getProperty("zookeeper.session.timeout.ms")),
      Integer.valueOf(standardProps.getProperty("zookeeper.connection.timeout.ms")), new ZooKeeperStringSerializer());
    AdminUtils.deleteTopic(zkUtils, topic);
    zk.close();
  } finally {
    zkUtils.close();
  }
}

代码示例来源：origin: org.apache.flink/flink-connector-kafka-0.10_2.11

@Override
public void deleteTestTopic(String topic) {
  ZkUtils zkUtils = getZkUtils();
  try {
    LOG.info("Deleting topic {}", topic);
    ZkClient zk = new ZkClient(zookeeperConnectionString, Integer.valueOf(standardProps.getProperty("zookeeper.session.timeout.ms")),
      Integer.valueOf(standardProps.getProperty("zookeeper.connection.timeout.ms")), new ZooKeeperStringSerializer());
    AdminUtils.deleteTopic(zkUtils, topic);
    zk.close();
  } finally {
    zkUtils.close();
  }
}

文章推荐： org.jvyaml.YAML.load()方法的使用及代码示例

文章推荐： jodd.io.ZipUtil.close()方法的使用及代码示例

reactjs - React TestUtils，如何模拟文档mouseMove？
我想在文档上使用TestUtils.Simulate.mouseMove。我有一个组件 Dragger，它向 document 添加一个 mouseMove 事件监听器。这是一个不完整的版本: //
java - 找不到符号: variable TestUtils
我编写了一个Java程序，可以分析基因表达数据的.soft文件并将其写入txt package il.ac.tau.cs.sw1.bioinformatics; import org.apache.c
javascript - React TestUtils，在文本框中输入不起作用
我正在使用 React.js 和 Jasmine 为文本输入元素编写单元测试。我试图简单地输入输入 React.TestUtils 并且没有运气。测试它的目的是限制文本框中可以放置的字符数。在应用程序
javascript - 在 reactjs TestUtils 中找不到带有标签的组件
这几天我一直在努力弄清楚为什么这不起作用。我真的很难让 reactjs TestUtils 工作，即使我将它简化为最简单的示例: describe('Layout', function() {
javascript - 使用 React testutils 模拟拖放不起作用
我正在尝试使用 jasmine、karma 和 React TestUtils 测试我的 ReactJS 混入的拖放功能。没有抛出异常，但是在调试时，似乎在模拟事件时绑定(bind)到事件监听器的函
javascript - 使用 TestUtils.Simulate 在输入元素上创建更改事件时遇到问题
我正在尝试为“Thinking in React”(http://facebook.github.io/react/docs/thinking-in-react.html)中所示的示例 Jest 编写
javascript - 使用 reactJs TestUtils 模拟文本输入
我希望能够使用 reactjs 模拟用户在文本框中键入内容，以便测试我的验证状态消息。我有一个在 keyUp 上验证的 react 组件下面是我尝试过的一个简单示例。 nameInput.prop
jasmine - 在 TestUtils 中使用 CSS 选择器查找组件
我正在使用 TestUtils 为我的 React 组件编写一些简单的测试，我发现 TestUtils.FindRenderedDOMComponentWithClass 和 TestUtils.Fi
reactjs - 使用 React TestUtils Simulate 选择选项
我有以下 React 组件，我想使用 TestUtils 选择我的选择 block 中的 selectElements 之一。我该怎么做？ var selectElements = ["type_a"
javascript - React TestUtils 不适用于装饰器或如何使用 rewire 模拟高阶函数
我有一个高阶组件: import React from 'react'; function withMUI(ComposedComponent) { return class withMUI {
unit-testing - 使用 golang prometheus testutil 进行单元测试
我们可以断言使用 testutil.CollectAndCount 注册和收集了一个指标。和 testutil.CollectAndCompare等等但是有没有办法通过指标名称和标签收集指标(如果它
javascript - TestUtils 获取在 "root"渲染的 React 元素
我有一个直接在“根”(document.body) 上呈现的 React 组件，我想使用 TestUtils 获取此元素，但我不想保留对此元素的引用。有什么办法吗？基本上我想要这样的东西: Reac
java - kafka jar 不包含 kafka.utils.testutils
我正在尝试为 kafka 生产者/消费者编写一个单元测试测试用例，并遇到了一个简单的例子 http://grokbase.com/t/kafka/users/13ck94p302/writing-un
javascript - React.addons.TestUtils.Simulate.scroll 不工作
我正在尝试使用 ReactJS 和 JSDOM 模拟滚动事件。最初我尝试了以下方法: var footer = TestUtils.findRenderedDOMComponentWithClass
javascript - React 的 TestUtils.Simulate.keyDown 不起作用
我的应用程序中有很多组件可以响应不同的按键操作，到目前为止，我使用 TestUtils.Simulate.keyDown 的测试都无法正常工作。似乎 keyDown 简单明了是行不通的。这是我要测试
org.apache.flink.streaming.connectors.kafka.testutils.ZooKeeperStringSerializer类的使用及代码示例
本文整理了Java中org.apache.flink.streaming.connectors.kafka.testutils.ZooKeeperStringSerializer类的一些代码示例，展示
coffeescript - 使用 Jest 和 TestUtils 测试 React 表单提交
我在测试表单时遇到问题 submit使用 React、TestUtils 和 Jest 的事件。我有一个渲染的组件DOM 元素；同一组件还有一个处理 onSubmit 的方法事件并记录一条语句。
javascript - 使用 React.addons.TestUtils 来 reactjs 测试组件
我正在阅读 reactjs 文档，但我很难完全理解它。我希望有更多分步示例。我希望能够测试我的组件及其子组件，但我不确定如何创建组件的模拟或实例来测试它们。代码: import React fro
testing - 无法在 Gradle 中解析类 org.gradle.util.TestUtil
这个错误意味着类 TestUtil 不在类路径中，编译器找不到它。我以前遇到过这样的错误一百次，缺少 Jar 或写错了类名，但现在我只是不知道出了什么问题。在我的 buildSrc 目录中，我有自定义
javascript - 使用 Jest 和 React JS TestUtils 测试表单
我有一个带有 3 个单选按钮的表单，如下所示(假名): 而且我很难尝试测试 onChange 和 onSubmit 事件。 inputs = TestUtils.scryRenderedDO

知者

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城