Commit 74e5c0fa authored by Randall Hauch's avatar Randall Hauch
Browse files

CC-1096 Added ES error message when unable to create an index

parent 1ef6b352

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

+2 −1
Original line number Diff line number Diff line
@@ -247,7 +247,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);