Commit 12300ac6 authored by Shikhar Bhushan's avatar Shikhar Bhushan
Browse files

minor: naming

parent 45a3ed45

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

+3 −3
Original line number Diff line number Diff line
@@ -167,9 +167,9 @@ public class ElasticsearchWriter { 
  }



  public void write(Collection<SinkRecord> records) {

    for (SinkRecord record : records) {

      IndexableRecord request = DataConverter.convertRecord(record, type, client, ignoreKey, ignoreSchema, topicConfigs, mappings);

      bulkProcessor.add(request, flushTimeoutMs);

    for (SinkRecord sinkRecord : records) {

      final IndexableRecord indexableRecord = DataConverter.convertRecord(sinkRecord, type, client, ignoreKey, ignoreSchema, topicConfigs, mappings);

      bulkProcessor.add(indexableRecord, flushTimeoutMs);

    }

  }