Unverified Commit 3fa8088c authored by Arjun Satish's avatar Arjun Satish Committed by GitHub
Browse files

Merge pull request #151 from wicknicks/CC-190 

CC-190: Deprecate the topic.index.map configuration option
parents 77f15243 11694597

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, such as RegexRouter, 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

+6 −2
Original line number Diff line number Diff line
@@ -70,10 +70,14 @@ 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

  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 "

      + "of ``topic:index`` pairs.";

      "This option is now deprecated. A future version may remove it completely. Please use "

          + "single message transforms, such as RegexRouter, to map topic names to index names.\n"

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

          + "a list of ``topic:index`` pairs.";

  public static final String KEY_IGNORE_CONFIG = "key.ignore";

  public static final String TOPIC_KEY_IGNORE_CONFIG = "topic.key.ignore";

  public static final String SCHEMA_IGNORE_CONFIG = "schema.ignore";

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

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

  private final boolean ignoreSchema;

  private final Set<String> ignoreSchemaTopics;

  @Deprecated

  private final Map<String, String> topicToIndexMap;

  private final long flushTimeoutMs;

  private final BulkProcessor<IndexableRecord, ?> bulkProcessor;