[hotfix] [docs] Fix typo in Elasticsearch example

static-max · Aug 15, 2018 · e91b2d5 · e91b2d5
1 parent a40a659
commit e91b2d5
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/docs/dev/connectors/elasticsearch.md b/docs/dev/connectors/elasticsearch.md
@@ -223,7 +223,7 @@ ElasticsearchSink.Builder<String> esSinkBuilder = new ElasticsearchSink.Builder<
 builder.setBulkFlushMaxActions(1);
 
 // provide a RestClientFactory for custom configuration on the internally created REST client
-builder.setRestClientBuilder(
+builder.setRestClientFactory(
  restClientBuilder -> {
  restClientBuilder.setDefaultHeaders(...)
  restClientBuilder.setMaxRetryTimeoutMillis(...)
@@ -360,7 +360,7 @@ val esSinkBuilder = new ElasticsearchSink.Builer[String](
 builder.setBulkFlushMaxActions(1)
 
 // provide a RestClientFactory for custom configuration on the internally created REST client
-builder.setRestClientBuilder(
+builder.setRestClientFactory(
  restClientBuilder -> {
  restClientBuilder.setDefaultHeaders(...)
  restClientBuilder.setMaxRetryTimeoutMillis(...)