本文整理了Java中com.salesforce.kafka.test.ZookeeperTestServer.start()
方法的一些代码示例,展示了ZookeeperTestServer.start()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZookeeperTestServer.start()
方法的具体详情如下:
包路径:com.salesforce.kafka.test.ZookeeperTestServer
类名称:ZookeeperTestServer
方法名:start
[英]Starts the internal Test zookeeper server instance.
[中]启动内部测试zookeeper服务器实例。
代码示例来源:origin: salesforce/kafka-junit
/**
* Here we stand up an internal test zookeeper service.
* once for all tests that use this shared resource.
* @throws RuntimeException on startup errors.
*/
private void before() throws RuntimeException {
getZookeeperTestServer().start();
}
代码示例来源:origin: com.salesforce.kafka.test/kafka-junit4
/**
* Here we stand up an internal test zookeeper service.
* once for all tests that use this shared resource.
* @throws RuntimeException on startup errors.
*/
private void before() throws RuntimeException {
getZookeeperTestServer().start();
}
代码示例来源:origin: salesforce/kafka-junit
/**
* Here we stand up an internal test zookeeper service.
* once for all tests that use this shared resource.
* @throws RuntimeException on startup errors.
*/
@Override
public void beforeAll(ExtensionContext context) throws RuntimeException {
getZookeeperTestServer().start();
}
代码示例来源:origin: salesforce/kafka-junit
/**
* Restarts the internal Test zookeeper server instance.
*/
public void restart() {
// If we have no instance yet
if (zkServer == null) {
// Call start instead and return.
start();
return;
}
// Otherwise call restart.
try {
zkServer.restart();
} catch (final Exception exception) {
throw new RuntimeException(exception.getMessage(), exception);
}
}
代码示例来源:origin: salesforce/kafka-junit
zookeeperTestServer.start();
内容来源于网络,如有侵权,请联系作者删除!