Kafka Не удалось создать новый клиент KafkaAdminCerber в кластере Kerberized - PullRequest
Новая
       39

Kafka Не удалось создать новый клиент KafkaAdminCerber в кластере Kerberized

0 голосов
/ 13 февраля 2020

У меня есть керберизованный кластер с Кафкой на нем. Я хочу использовать реестр Confluent Schema с Kafka на кластере. Запустив реестр схем из моего локального p c, все работает просто отлично. Но когда я загрузил его на компьютер в кластере и попытался запустить с него, я получил:

Ошибка 

 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

ВОПРОСЫ: Почему это работает в моем локальном p c, а не на машине в кластере? Что я должен изменить?

PS Я получаю тот же результат, даже пытаясь запустить CMAK yahoo kafka-manager (используя тот же jaas.confing и тот же keytab)

...