Loading src/main/java/io/confluent/connect/elasticsearch/ElasticsearchSinkConnectorConfig.java +4 −2 Original line number Diff line number Diff line Loading @@ -74,8 +74,10 @@ public class ElasticsearchSinkConnectorConfig extends AbstractConfig { @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"; Loading Loading
src/main/java/io/confluent/connect/elasticsearch/ElasticsearchSinkConnectorConfig.java +4 −2 Original line number Diff line number Diff line Loading @@ -74,8 +74,10 @@ public class ElasticsearchSinkConnectorConfig extends AbstractConfig { @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"; Loading