[jira] [Commented] (FLINK-11346) Could not enable basic authentication with elastic search connector

["Dawid Wysakowicz (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-11346?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16744091#comment-16744091 ] 

Dawid Wysakowicz commented on FLINK-11346:
------------------------------------------

You should post those kind of question to user mailing list: https://flink.apache.org/community.html#mailing-lists

Isn't the problem that you should use `restClientBuilder => ` rather than `restClientBuilder ->` as you are writing in scala? 

I will close this ticket, please reach out to mailing list if you need more help.

> Could not enable basic authentication with elastic search connector
> -------------------------------------------------------------------
>
>                 Key: FLINK-11346
>                 URL: https://issues.apache.org/jira/browse/FLINK-11346
>             Project: Flink
>          Issue Type: Bug
>          Components: ElasticSearch Connector
>            Reporter: kannan
>            Priority: Blocker
>
> Hello Team, 
> I am trying to add elasticsearch as sink and my current elasticsearch has enabled SSL and Basic authentication. 
> I could not connect to elasticsearch with basic authentication. 
> ===========
> code:
> val credentialsProvider = new BasicCredentialsProvider
>  credentialsProvider.setCredentials(AuthScope.ANY, new UsernamePasswordCredentials("user", "password"))
> esSinkBuilder.setRestClientFactory(
>  restClientBuilder -> {
>  restClientBuilder.setHttpClientConfigCallback(new RestClientBuilder.HttpClientConfigCallback()
> { override def customizeHttpClient(httpClientBuilder: HttpAsyncClientBuilder) = httpClientBuilder .setDefaultCredentialsProvider(credentialsProvider) }
> )
>  }
>  )
> ===========
>  
> Error Log:
> Error:(70, 7) not found: value restClientBuilder
>  restClientBuilder -> {
>  
> Application version used 
> scala - 2.11
> flink - 1.7
> elasticsearch - 6.5
> elasticsearch connector version - 2.11



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)