Kafka не удалось создать новый клиент KafkaAdminClient в кластере с Kerberized
У меня есть керберизованный кластер с Kafka. Я хочу использовать Confluent Schema Registry с Kafka в кластере. Запуская реестр схем с моего локального компьютера, все работает нормально. Но когда я загрузил его на машину в кластере и попытался запустить с него, я получил:
ошибка
ERROR Server died unexpectedly: (io.confluent.kafka.schemaregistry.rest.SchemaRegistryMain:50)
org.apache.kafka.common.KafkaException: Failed to create new KafkaAdminClient
...
Caused by: org.apache.kafka.common.KafkaException: javax.security.auth.login.LoginException: Message stream modified (41)
...
Caused by: javax.security.auth.login.LoginException: Message stream modified (41)
Я также попытался запустить его с другой машины в кластере и получил тот же результат.
Schema-registry.properties
listeners=http://0.0.0.0:8081
kafkastore.connection.url=master01.domain.ext:2181,master02.domain.ext:2181
kafkastore.bootstrap.servers=SASL_PLAINTEXT://xxx.domain.ext:6667,SASL_PLAINTEXT://xxx.domain.ext:6667
kafkastore.topic=_schemas
debug=true
kafkastore.sasl.jaas.config=com.sun.security.auth.module.Krb5LoginModule required \
useKeyTab=true \
storeKey=true \
keyTab="/path/schema-registry/etc/schema-registry/my-keytab.keytab" \
principal="kafka/xxx.domain.ext@DOMAIN.EXT";
kafkastore.sasl.kerberos.service.name=kafka
kafkastore.security.protocol=SASL_PLAINTEXT
kafkastore.sasl.mechanism=GSSAPI
КОМАНДА ВЫПОЛНЕНИЯ:
sudo bash bin/schema-registry-start ./etc/schema-registry/schema-registry.properties
ВОПРОСЫ: Почему это работает на моем локальном компьютере, а не на машине в кластере? Что мне следует изменить?
PS я получаю тот же результат, даже пытаясь запустить CMAK yahoo kafka-manager (используя тот же jaas.confing и тот же keytab)