docs update, minor typos

Author: DarioBalinzo

README.md

@@ -131,6 +131,33 @@ to avoid data losses when paginating (available starting from versions >= 1.4).
 * Type: any
 * Importance: low
 
+
+``es.tls.truststore.location``
+Elastic ssl truststore location
+
+* Type: string
+* Importance: medium
+
+``es.tls.truststore.password``
+Elastic ssl truststore password
+
+* Type: string
+* Default: ""
+* Importance: medium
+
+``es.tls.keystore.location``
+Elasticsearch keystore location
+
+* Type: string
+* Importance: medium
+
+``es.tls.keystore.password``
+Elasticsearch keystore password
+
+* Type: string
+* Default: ""
+* Importance: medium
+
 ``connection.attempts``
 Maximum number of attempts to retrieve a valid Elasticsearch connection.
 

doc/README.md

@@ -124,13 +124,40 @@ The name of the strictly incrementing field to use to detect new records.
 * Importance: high
 
 ``incrementing.secondary.field.name``
-In case the main incrementing field may have duplicates,
-this secondary field is used as a secondary sort field in order
+In case the main incrementing field may have duplicates, 
+this secondary field is used as a secondary sort field in order 
 to avoid data losses when paginating (available starting from versions >= 1.4).
 
 * Type: any
 * Importance: low
 
+
+``es.tls.truststore.location``
+Elastic ssl truststore location
+
+* Type: string
+* Importance: medium
+
+``es.tls.truststore.password``
+Elastic ssl truststore password
+
+* Type: string
+* Default: ""
+* Importance: medium
+
+``es.tls.keystore.location``
+Elasticsearch keystore location
+
+* Type: string
+* Importance: medium
+
+``es.tls.keystore.password``
+Elasticsearch keystore password
+
+* Type: string
+* Default: ""
+* Importance: medium
+
 ``connection.attempts``
 Maximum number of attempts to retrieve a valid Elasticsearch connection.
 
@@ -152,6 +179,13 @@ Indices prefix to include in copying.
 * Default: ""
 * Importance: medium
 
+``index.names``
+List of elasticsearch indices: `es1,es2,es3`
+
+* Type: string
+* Default: null
+* Importance: medium
+
 ### Connector Configuration
 
 ``poll.interval.ms``
@@ -183,6 +217,15 @@ nested fields. To provide multiple fields use `;` as separator
 * Importance: medium
 * Default: null
 
+``filters.blacklist``
+Blacklist filter for extracting a subset of fields from elastic-search json documents. The blacklist filter supports
+nested fields. To provide multiple fields use `;` as separator
+(e.g. `customer;order.qty;order.price`).
+
+* Type: string
+* Importance: medium
+* Default: null
+
 ``filters.json_cast``
 This filter casts nested fields to json string, avoiding parsing recursively as kafka connect-schema. The json-cast
 filter supports nested fields. To provide multiple fields use `;` as separator

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

@@ -76,8 +76,8 @@ public void start(Map<String, String> props) {
 
         String truststore = config.getString(ElasticSourceConnectorConfig.ES_TRUSTSTORE_CONF);
         String truststorePass = config.getString(ElasticSourceConnectorConfig.ES_TRUSTSTORE_PWD_CONF);
-        String keystore = config.getString(ElasticSourceConnectorConfig.ES_TRUSTSTORE_CONF);
-        String keystorePass = config.getString(ElasticSourceConnectorConfig.ES_TRUSTSTORE_PWD_CONF);
+        String keystore = config.getString(ElasticSourceConnectorConfig.ES_KEYSTORE_CONF);
+        String keystorePass = config.getString(ElasticSourceConnectorConfig.ES_KEYSTORE_PWD_CONF);
 
         if (truststore != null) {
             connectionBuilder.withTrustStore(truststore, truststorePass);

src/main/java/com/github/dariobalinzo/task/ElasticSourceTask.java

@@ -92,6 +92,8 @@ public void start(Map<String, String> properties) {
 
         topic = config.getString(ElasticSourceConnectorConfig.TOPIC_PREFIX_CONFIG);
         cursorField = config.getString(ElasticSourceConnectorConfig.INCREMENTING_FIELD_NAME_CONFIG);
+        Objects.requireNonNull(cursorField, ElasticSourceConnectorConfig.INCREMENTING_FIELD_NAME_CONFIG
+                + " conf is mandatory");
         cursorFieldJsonName = removeKeywordSuffix(cursorField);
         secondaryCursorField = config.getString(ElasticSourceConnectorConfig.SECONDARY_INCREMENTING_FIELD_NAME_CONFIG);
         secondaryCursorFieldJsonName = removeKeywordSuffix(secondaryCursorField);
@@ -165,8 +167,8 @@ private void initEsConnection() {
 
         String truststore = config.getString(ElasticSourceConnectorConfig.ES_TRUSTSTORE_CONF);
         String truststorePass = config.getString(ElasticSourceConnectorConfig.ES_TRUSTSTORE_PWD_CONF);
-        String keystore = config.getString(ElasticSourceConnectorConfig.ES_TRUSTSTORE_CONF);
-        String keystorePass = config.getString(ElasticSourceConnectorConfig.ES_TRUSTSTORE_PWD_CONF);
+        String keystore = config.getString(ElasticSourceConnectorConfig.ES_KEYSTORE_CONF);
+        String keystorePass = config.getString(ElasticSourceConnectorConfig.ES_KEYSTORE_PWD_CONF);
 
         if (truststore != null) {
             connectionBuilder.withTrustStore(truststore, truststorePass);