Loading docs/elasticsearch_connector.rst +3 −8 Original line number Diff line number Diff line Loading @@ -82,17 +82,12 @@ is available in Elasticsearch:: "_id" : "test-elasticsearch-sink+0+0", "_score" : 1.0, "_source" : { "_children" : { "f1" : { "_value" : "value1" } }, "_nodeFactory" : { "_cfgBigDecimalExact" : false } "f1" : "value1" } }] } } Features -------- The Elasticsearch connector offers a bunch of features: Loading src/main/java/io/confluent/connect/elasticsearch/internals/HttpClient.java +1 −1 Original line number Diff line number Diff line Loading @@ -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()) Loading Loading
docs/elasticsearch_connector.rst +3 −8 Original line number Diff line number Diff line Loading @@ -82,17 +82,12 @@ is available in Elasticsearch:: "_id" : "test-elasticsearch-sink+0+0", "_score" : 1.0, "_source" : { "_children" : { "f1" : { "_value" : "value1" } }, "_nodeFactory" : { "_cfgBigDecimalExact" : false } "f1" : "value1" } }] } } Features -------- The Elasticsearch connector offers a bunch of features: Loading
src/main/java/io/confluent/connect/elasticsearch/internals/HttpClient.java +1 −1 Original line number Diff line number Diff line Loading @@ -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()) Loading