Commit ca32acfc authored by Randall Hauch's avatar Randall Hauch
Browse files

Merge branch '3.1.x' into 3.2.x

parents c5df09d8 8b084148

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

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

          JestResult result = client.execute(createIndex);

          if (!result.isSucceeded()) {

            throw new ConnectException("Could not create index:" + index);

            String msg = result.getErrorMessage() != null ? ": " + result.getErrorMessage() : "";

            throw new ConnectException("Could not create index '" + index + "'" + msg);

          }

        } catch (IOException e) {

          throw new ConnectException(e);