Commit 6e4756b3 authored by Liquan Pei's avatar Liquan Pei
Browse files

Fix data format

parent 1efe6ca8

docs/elasticsearch_connector.rst

+1 −7
Original line number Diff line number Diff line
@@ -82,14 +82,8 @@ is available in Elasticsearch:: 
       "_id" : "test-elasticsearch-sink+0+0",

       "_score" : 1.0,

       "_source" : {

         "_children" : {

           "f1" : {

             "_value" : "value1"

           }

           "f1" : "value1"

         },

         "_nodeFactory" : {

           "_cfgBigDecimalExact" : false

         }

       }

     }]

   }

src/main/java/io/confluent/connect/elasticsearch/internals/HttpClient.java

+1 −1
Original line number Diff line number Diff line
@@ -62,7 +62,7 @@ public class HttpClient implements Client<Response> { 
      } catch (IOException e) {

        callback.onFailure(e);

      }

      Index index = new Index.Builder(data)

      Index index = new Index.Builder(data.toString())

          .index(request.getIndex())

          .type(request.getType())

          .id(request.getId())