Skip to content

Commit 72f996e

Browse files
committed
clean up blank lines
1 parent b7867f2 commit 72f996e

File tree

2 files changed

+0
-5
lines changed

2 files changed

+0
-5
lines changed

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

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -189,7 +189,6 @@ public ElasticsearchWriter build() {
189189
}
190190

191191
public void write(Collection<SinkRecord> records) {
192-
193192
for (SinkRecord sinkRecord : records) {
194193
final String index = convertTopicToIndexName(sinkRecord.topic());
195194
final boolean ignoreKey = ignoreKeyTopics.contains(sinkRecord.topic()) || this.ignoreKey;
@@ -211,10 +210,8 @@ public void write(Collection<SinkRecord> records) {
211210

212211
bulkProcessor.add(indexableRecord, flushTimeoutMs);
213212
}
214-
215213
}
216214

217-
218215
/**
219216
* Return the expected index name for a given topic, using the configured mapping or the topic name. Elasticsearch
220217
* <a href="https://github.com/elastic/elasticsearch/issues/29420">accepts only lowercase index names</a>.

src/test/java/io/confluent/connect/elasticsearch/ElasticsearchSinkTaskTest.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,5 @@ public void testCreateAndWriteToIndexForTopicWithUppercaseCharacters() {
110110
} finally {
111111
task.stop();
112112
}
113-
114113
}
115-
116114
}

0 commit comments

Comments
 (0)