При запуске KSQL на защищенном сервере SASL Confluent выдается ошибка «Значение не указано для ключа« в конфигурации JAAS » - PullRequest
Новая
       15

При запуске KSQL на защищенном сервере SASL Confluent выдается ошибка «Значение не указано для ключа« в конфигурации JAAS »

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

При запуске KSQL с помощью файла ksql-server.properties с: 

sasl.jaas.config=org.apache.kafka.common.security.scram.ScramLoginModule required \
        username="<username>" \
        password="<password with @ and special chars>";
security.protocol=SASL_PLAINTEXT
sasl.mechanism=SCRAM-SHA-256

Я получаю сообщение об ошибке: 

ERROR Failed to start KSQL (io.confluent.ksql.rest.server.KsqlServerMain:48)
org.apache.kafka.common.KafkaException: Failed create new KafkaAdminClient
    at org.apache.kafka.clients.admin.KafkaAdminClient.createInternal(KafkaAdminClient.java:370)
    at org.apache.kafka.clients.admin.AdminClient.create(AdminClient.java:62)
    at io.confluent.ksql.util.KafkaTopicClientImpl.<init>(KafkaTopicClientImpl.java:66)
    at io.confluent.ksql.KsqlEngine.<init>(KsqlEngine.java:120)
    at io.confluent.ksql.rest.server.KsqlRestApplication.buildApplication(KsqlRestApplication.java:252)
    at io.confluent.ksql.rest.server.KsqlServerMain.createExecutable(KsqlServerMain.java:83)
    at io.confluent.ksql.rest.server.KsqlServerMain.main(KsqlServerMain.java:45)
Caused by: java.lang.IllegalArgumentException: Value not specified for key 'â' in JAAS config
    at org.apache.kafka.common.security.JaasConfig.parseAppConfigurationEntry(JaasConfig.java:116)
    at org.apache.kafka.common.security.JaasConfig.<init>(JaasConfig.java:63)
    at org.apache.kafka.common.security.JaasContext.load(JaasContext.java:90)
    at org.apache.kafka.common.security.JaasContext.loadClientContext(JaasContext.java:84)
    at org.apache.kafka.common.network.ChannelBuilders.create(ChannelBuilders.java:119)
    at org.apache.kafka.common.network.ChannelBuilders.clientChannelBuilder(ChannelBuilders.java:65)
    at org.apache.kafka.clients.ClientUtils.createChannelBuilder(ClientUtils.java:88)
    at org.apache.kafka.clients.admin.KafkaAdminClient.createInternal(KafkaAdminClient.java:346)

конкретно ошибка: 

Value not specified for key 'â' in JAAS config

сбивает меня с толку - ключи в конфиге JAAS должны состоять только из имени пользователя и пароля - верно?

создал файл client.properties на моем смежном сервере с точно таким же именем пользователя и паролем SASL_Plaintext.

...