Commit 28623a97 authored by Shikhar Bhushan's avatar Shikhar Bhushan
Browse files

Override index if topic in 'topic.index.map'

parent 81a24a20

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

+2 −1
Original line number Diff line number Diff line
@@ -190,7 +190,8 @@ public class ElasticsearchWriter { 


  public void write(Collection<SinkRecord> records) {

    for (SinkRecord sinkRecord : records) {

      final String index = sinkRecord.topic();

      final String indexOverride = topicToIndexMap.get(sinkRecord.topic());

      final String index = indexOverride != null ? indexOverride : sinkRecord.topic();

      final boolean ignoreKey = ignoreKeyTopics.contains(sinkRecord.topic()) || this.ignoreKey;

      final boolean ignoreSchema = ignoreSchemaTopics.contains(sinkRecord.topic()) || this.ignoreSchema;