Commit aac7a2a5 authored by Arjun Satish's avatar Arjun Satish
Browse files

Deprecate the topic.index.map configuration option 



Signed-off-by: default avatarArjun Satish <arjun@confluent.io>
parent 77f15243

docs/configuration_options.rst

+2 −0
Original line number Diff line number Diff line
@@ -96,6 +96,8 @@ Data Conversion 
  * Importance: low



``topic.index.map``

  This option is now deprecated. A future version may remove it completely. Please use single message transforms to map topic names to index names.



  A map from Kafka topic name to the destination Elasticsearch index, represented as a list of ``topic:index`` pairs.



  * Type: list

src/main/java/io/confluent/connect/elasticsearch/ElasticsearchSinkConnectorConfig.java

+5 −0
Original line number Diff line number Diff line
@@ -70,6 +70,11 @@ public class ElasticsearchSinkConnectorConfig extends AbstractConfig { 


  public static final String TYPE_NAME_CONFIG = "type.name";

  private static final String TYPE_NAME_DOC = "The Elasticsearch type name to use when indexing.";



  /**

   * @deprecated This option is now deprecated. A future version may remove it completely. Please

   * use single message transforms to map topic names to index names.

   */

  public static final String TOPIC_INDEX_MAP_CONFIG = "topic.index.map";

  private static final String TOPIC_INDEX_MAP_DOC =

      "A map from Kafka topic name to the destination Elasticsearch index, represented as a list "

src/main/java/io/confluent/connect/elasticsearch/ElasticsearchWriter.java

+3 −0
Original line number Diff line number Diff line
@@ -46,6 +46,9 @@ public class ElasticsearchWriter { 
  private final Set<String> ignoreKeyTopics;

  private final boolean ignoreSchema;

  private final Set<String> ignoreSchemaTopics;

  /**

   * @deprecated This field is now deprecated. A future version may remove it completely.

   */

  private final Map<String, String> topicToIndexMap;

  private final long flushTimeoutMs;

  private final BulkProcessor<IndexableRecord, ?> bulkProcessor;