Клиентское соединение KSQL по sasl - PullRequest
Новая
       8

Клиентское соединение KSQL по sasl

0 голосов
/ 26 сентября 2019

Я хочу подключиться к ksql с помощью моего acls. 

"SET 'ksql.streams.sasl.jaas.config'='org.apache.kafka.common.security.scram.ScramLoginModule required username=my_user password=my_password'

Ошибка: 

 Error issuing POST to KSQL server. path:ksql
Caused by: com.fasterxml.jackson.databind.exc.InvalidDefinitionException: No
       serializer found for class org.apache.kafka.common.config.types.Password and no
       properties discovered to create BeanSerializer (to avoid exception, disable
       SerializationFeature.FAIL_ON_EMPTY_BEANS) (through reference chain:
       io.confluent.ksql.rest.entity.KsqlRequest["streamsProperties"]->java.util.HashMa
       p["ksql.streams.sasl.jaas.config"])
Caused by: No serializer found for class
       org.apache.kafka.common.config.types.Password and no properties discovered to
       create BeanSerializer (to avoid exception, disable
       SerializationFeature.FAIL_ON_EMPTY_BEANS) (through reference chain:
       io.confluent.ksql.rest.entity.Ksql

Запрос ["streamsProperties"] -> java.util.HashMa p ["ksql.streams.sasl.jaas.config "])

...