With elasticsearch 2.x I used the following code to launch an embedded Node for testing:
@Bean
public Node elasticSearchTestNode() {
return NodeBuilder.nodeBuilder()
.settings(Settings.settingsBuilder()
.put("http.enabled", "true")
.put("path.home", "elasticsearch-data")
.build())
.node();
}
This does not compile any more. How can I start an embedded node in 5.x ?
Embedding elasticsearch is no longer officially supported, and it's a bit more complicated than in 2.x, but it works.
You need to add some dependencies:
<dependency>
<groupId>org.elasticsearch</groupId>
<artifactId>elasticsearch</artifactId>
<version>5.1.1</version>
<scope>test</scope>
</dependency>
<dependency><!-- required by elasticsearch -->
<groupId>org.elasticsearch.plugin</groupId>
<artifactId>transport-netty4-client</artifactId>
<version>5.1.1</version>
<scope>test</scope>
</dependency>
<dependency><!-- required by elasticsearch -->
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-api</artifactId>
<version>2.7</version>
</dependency>
And then launch a node like this:
@Bean
public Node elasticSearchTestNode() throws NodeValidationException {
Node node = new MyNode(
Settings.builder()
.put("transport.type", "netty4")
.put("http.type", "netty4")
.put("http.enabled", "true")
.put("path.home", "elasticsearch-data")
.build(),
asList(Netty4Plugin.class));
node.start();
return node;
}
private static class MyNode extends Node {
public MyNode(Settings preparedSettings, Collection<Class<? extends Plugin>> classpathPlugins) {
super(InternalSettingsPreparer.prepareEnvironment(preparedSettings, null), classpathPlugins);
}
}
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With