Не удалось включить базовую проверку подлинности с помощью эластичного соединителя поиска - PullRequest
Новая
       11

Не удалось включить базовую проверку подлинности с помощью эластичного соединителя поиска

0 голосов
/ 16 января 2019

Я пытаюсь добавить эластичный поиск в качестве приемника, и мой текущий эластичный поиск включил SSL и обычную аутентификацию.

Я не могу подключиться кasticsearch с базовой аутентификацией.

Журнал ошибок:

Ошибка: (70, 7) не найдено: значение restClientBuilder restClientBuilder -> {

Используемая версия приложения

Скала - 2.11

моргание - 1,7

эластичный поиск - 6,5

версия разъема эластичного поиска - 2.11 

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) }
)
}
)
...