chore(deps) : Upgrade to 8.11.3 version of elasticsearch (#1271)

* chore(deps) : Upgrade to 8.11.3 version of elasticsearch

* polish sample

boot-data-elasticsearch/src/main/java/com/example/demo/DemoApplication.java

@@ -82,12 +82,12 @@ public Mono<Post> create(@RequestBody Post post) {
     }
 
     @GetMapping("/{id}")
-    public Mono<Post> get(@PathVariable("id") String id) {
+    public Mono<Post> get(@PathVariable String id) {
         return this.posts.findById(id);
     }
 
     @PutMapping("/{id}")
-    public Mono<Post> update(@PathVariable("id") String id, @RequestBody Post post) {
+    public Mono<Post> update(@PathVariable String id, @RequestBody Post post) {
         return this.posts.findById(id)
                 .map(p -> {
                     p.setTitle(post.getTitle());
@@ -99,7 +99,7 @@ public Mono<Post> update(@PathVariable("id") String id, @RequestBody Post post)
     }
 
     @DeleteMapping("/{id}")
-    public Mono<Void> delete(@PathVariable("id") String id) {
+    public Mono<Void> delete(@PathVariable String id) {
         return this.posts.deleteById(id);
     }
 

boot-data-elasticsearch/src/main/resources/application.properties

@@ -2,5 +2,4 @@
 spring.elasticsearch.uris=localhost:9200
 spring.elasticsearch.socket-timeout=10
 logging.level.com.example=DEBUG
-logging.level.sql=trace
 logging.level.org.springframework.data.elasticsearch.core.ReactiveElasticsearchTemplate=trace

boot-data-elasticsearch/src/test/java/com/example/demo/PostRepositoryWithTestContainersTest.java

@@ -23,6 +23,7 @@
 
 import java.time.Duration;
 import java.util.List;
+import java.util.Map;
 import java.util.concurrent.CountDownLatch;
 
 import static java.util.concurrent.TimeUnit.MILLISECONDS;
@@ -36,11 +37,11 @@
 // Testcontainers does not work well with per_class testinstance.
 // see: https://stackoverflow.com/questions/61357116/exception-mapped-port-can-only-be-obtained-after-the-container-is-started-when/61358336#61358336
 @TestInstance(TestInstance.Lifecycle.PER_METHOD)
-public class PostRepositoryWithTestContainersTest {
+class PostRepositoryWithTestContainersTest {
 
     @Container
-    static ElasticsearchContainer esContainer = new ElasticsearchContainer("docker.elastic.co/elasticsearch/elasticsearch:7.17.9")
-            .withEnv("discovery.type", "single-node");
+    static ElasticsearchContainer esContainer = new ElasticsearchContainer("docker.elastic.co/elasticsearch/elasticsearch:8.11.3")
+            .withEnv(Map.of("xpack.security.enabled", "false"));
 
     @DynamicPropertySource
     static void esProperties(DynamicPropertyRegistry registry) {
@@ -55,7 +56,7 @@ static void esProperties(DynamicPropertyRegistry registry) {
 
     @SneakyThrows
     @BeforeEach
-    public void setup() {
+    void setup() {
         var countDownLatch = new CountDownLatch(1);
         this.posts.deleteAll().block(Duration.ofMillis(1000));
 
@@ -87,15 +88,15 @@ void testDatabaseIsRunning() {
         assertThat(esContainer.isRunning()).isTrue();
     }
 
- //   @Test
-//    void testLoadData() {
-//        this.posts.findAll(Sort.by(Sort.Direction.ASC, "title"))
-//                .log()
-//                .as(StepVerifier::create)
-//                .consumeNextWith(user -> assertThat(user.getTitle()).isEqualTo("Post one"))
-//                .consumeNextWith(user -> assertThat(user.getTitle()).isEqualTo("Post two"))
-//                .verifyComplete();
-//    }
+   @Test
+   void testLoadData() {
+       this.posts.findAll(Sort.by(Sort.Direction.ASC, "title"))
+               .log()
+               .as(StepVerifier::create)
+               .consumeNextWith(user -> assertThat(user.getTitle()).isEqualTo("Post one"))
+               .consumeNextWith(user -> assertThat(user.getTitle()).isEqualTo("Post two"))
+               .verifyComplete();
+   }
 
     @Test
     void testSavedPostTitles() {