upgrading pom dependecies (#66)

resolves #63

Author: DarioBalinzo

README.md

@@ -173,7 +173,8 @@ Backoff time in milliseconds between connection attempts.
 * Importance: low
 
 ``index.prefix``
-Indices prefix to include in copying.
+Indices prefix to include in copying. 
+Periodically, new indices are discovered if they match the pattern.
 
 * Type: string
 * Default: ""

doc/README.md

@@ -173,7 +173,8 @@ Backoff time in milliseconds between connection attempts.
 * Importance: low
 
 ``index.prefix``
-Indices prefix to include in copying.
+Indices prefix to include in copying. 
+Periodically, new indices are discovered if they match the pattern.
 
 * Type: string
 * Default: ""

manifest.json

@@ -45,5 +45,5 @@
     "elastic"
   ],
   "title": "Kafka Connect Elasticsearch Source",
-  "version": "1.3"
+  "version": "1.5.0"
 }

pom.xml

@@ -27,7 +27,7 @@
 
     <groupId>com.github.dariobalinzo</groupId>
     <artifactId>elastic-source-connect</artifactId>
-    <version>1.4</version>
+    <version>1.5.0</version>
 
     <licenses>
         <license>
@@ -41,46 +41,46 @@
         <dependency>
             <groupId>org.apache.kafka</groupId>
             <artifactId>connect-api</artifactId>
-            <version>2.6.0</version>
+            <version>2.8.0</version>
         </dependency>
         <dependency>
             <groupId>org.elasticsearch.client</groupId>
             <artifactId>elasticsearch-rest-high-level-client</artifactId>
-            <version>6.2.3</version>
+            <version>7.16.1</version>
         </dependency>
         <dependency>
             <groupId>org.elasticsearch.client</groupId>
             <artifactId>elasticsearch-rest-client</artifactId>
-            <version>6.2.3</version>
+            <version>7.16.1</version>
         </dependency>
         <dependency>
             <groupId>junit</groupId>
             <artifactId>junit</artifactId>
-            <version>4.13.1</version>
+            <version>4.13.2</version>
             <scope>test</scope>
         </dependency>
         <dependency>
             <groupId>org.testcontainers</groupId>
             <artifactId>testcontainers</artifactId>
-            <version>1.15.0-rc2</version>
+            <version>1.16.2</version>
             <scope>test</scope>
         </dependency>
         <dependency>
             <groupId>org.testcontainers</groupId>
             <artifactId>elasticsearch</artifactId>
-            <version>1.15.0-rc2</version>
+            <version>1.16.2</version>
             <scope>test</scope>
         </dependency>
         <dependency>
             <groupId>ch.qos.logback</groupId>
             <artifactId>logback-core</artifactId>
-            <version>1.2.3</version>
+            <version>1.2.8</version>
             <scope>test</scope>
         </dependency>
         <dependency>
             <groupId>ch.qos.logback</groupId>
             <artifactId>logback-classic</artifactId>
-            <version>1.2.3</version>
+            <version>1.2.8</version>
             <scope>test</scope>
         </dependency>
         <dependency>
@@ -92,7 +92,7 @@
         <dependency>
             <groupId>com.fasterxml.jackson.core</groupId>
             <artifactId>jackson-databind</artifactId>
-            <version>2.11.1</version>
+            <version>2.13.0</version>
         </dependency>
     </dependencies>
 

src/main/java/com/github/dariobalinzo/Version.java

@@ -17,5 +17,5 @@
 package com.github.dariobalinzo;
 
 public class Version {
-    public static final String VERSION = "1.4";
+    public static final String VERSION = "1.5.0";
 }

src/main/java/com/github/dariobalinzo/elastic/ElasticRepository.java

@@ -20,6 +20,8 @@
 import com.github.dariobalinzo.elastic.response.PageResult;
 import org.elasticsearch.action.search.SearchRequest;
 import org.elasticsearch.action.search.SearchResponse;
+import org.elasticsearch.client.Request;
+import org.elasticsearch.client.RequestOptions;
 import org.elasticsearch.client.Response;
 import org.elasticsearch.index.query.QueryBuilder;
 import org.elasticsearch.search.builder.SearchSourceBuilder;
@@ -171,7 +173,7 @@ private SearchResponse executeSearch(SearchRequest searchRequest) throws IOExcep
         for (int i = 0; i < maxTrials; ++i) {
             try {
                 return elasticConnection.getClient()
-                        .search(searchRequest);
+                        .search(searchRequest, RequestOptions.DEFAULT);
             } catch (IOException e) {
                 lastError = e;
                 Thread.sleep(elasticConnection.getConnectionRetryBackoff());
@@ -183,9 +185,10 @@ private SearchResponse executeSearch(SearchRequest searchRequest) throws IOExcep
     public List<String> catIndices(String prefix) {
         Response resp;
         try {
+
             resp = elasticConnection.getClient()
                     .getLowLevelClient()
-                    .performRequest("GET", "/_cat/indices");
+                    .performRequest(new Request("GET", "/_cat/indices"));
         } catch (IOException e) {
             logger.error("error in searching index names");
             throw new RuntimeException(e);
@@ -212,7 +215,7 @@ public void refreshIndex(String index) {
         try {
             elasticConnection.getClient()
                     .getLowLevelClient()
-                    .performRequest("POST", "/" + index + "/_refresh");
+                    .performRequest(new Request("POST", "/" + index + "/_refresh"));
         } catch (IOException e) {
             logger.error("error in refreshing index " + index);
             throw new RuntimeException(e);

src/test/java/com/github/dariobalinzo/TestContainersContext.java

@@ -25,8 +25,9 @@
 import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest;
 import org.elasticsearch.action.index.IndexRequest;
 import org.elasticsearch.action.index.IndexResponse;
-import org.elasticsearch.common.xcontent.XContentBuilder;
-import org.elasticsearch.common.xcontent.XContentFactory;
+import org.elasticsearch.client.RequestOptions;
+import org.elasticsearch.xcontent.XContentBuilder;
+import org.elasticsearch.xcontent.XContentFactory;
 import org.junit.AfterClass;
 import org.junit.BeforeClass;
 import org.testcontainers.elasticsearch.ElasticsearchContainer;
@@ -76,7 +77,7 @@ public static void setupElastic() {
 
     protected void deleteTestIndex() {
         try {
-            connection.getClient().indices().delete(new DeleteIndexRequest(TEST_INDEX));
+            connection.getClient().indices().delete(new DeleteIndexRequest(TEST_INDEX), RequestOptions.DEFAULT);
         } catch (Exception ignored) {
 
         }
@@ -108,7 +109,7 @@ protected void insertMockData(int tsStart, String fullName, String index) throws
         indexRequest.type("_doc");
         indexRequest.source(builder);
 
-        IndexResponse response = connection.getClient().index(indexRequest);
+        IndexResponse response = connection.getClient().index(indexRequest, RequestOptions.DEFAULT);
         assertEquals(DocWriteResponse.Result.CREATED, response.getResult());
     }