Commit 567b1c29 authored by Chris Egerton's avatar Chris Egerton
Browse files

Change enum comparison from equals() to ==

parent 96fcc6f4

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

+1 −1
Original line number Diff line number Diff line
@@ -221,7 +221,7 @@ public class ElasticsearchWriter { 
  public void write(Collection<SinkRecord> records) {

    for (SinkRecord sinkRecord : records) {

      // Preemptively skip records with null values if they're going to be ignored anyways

      if (sinkRecord.value() == null && behaviorOnNullValues.equals(BehaviorOnNullValues.IGNORE)) {

      if (sinkRecord.value() == null && behaviorOnNullValues == BehaviorOnNullValues.IGNORE) {

        continue;

      }