Я работаю над защитой Kafka с помощью Kerberos в CDH 5.5 Версия Kafka: 2.0.1 Kerberos включен и отлично работает
когда я включаю sasl в kafka с помощью cloudera maneger, я получаю сообщение об ошибке:
29 июня, 15:02:42. 875 ИНФОРМАЦИЯ org.apache.zookeeper.ClientCnxn
Открытие сокетного соединения с сервером brahim.localhost / 127.0.0.1: 2181. Попытается выполнить SASL-аутентификацию с помощью раздела "Клиент" контекста входа.
29 июня, 15:02:42 879 INFO org.apache.zookeeper.ClientCnxn
Установлено сокетное соединение с brahim.localhost / 127.0.0.1: 2181, запуск сеанса
29 июня, 15:02:42. 906 PM INFO org.apache.zookeeper.ClientCnxn
Установление сеанса завершено на сервере brahim.localhost / 127.0.0.1: 2181, sessionid = 0x1559c20b6110007, согласованный тайм-аут = 30000
29 июня, 15: 02: 42: 910 PM INFO org.I0Itec.zkclient.ZkClient
Состояние zookeeper изменено (SyncConnected)
29 июня, 15:02:42. 942. ОШИБКА. Org.apache.zookeeper.client.ZooKeeperSaslClient.
Ошибка аутентификации SASL с использованием контекста входа «Клиент».
29 июня, 15:02:42 942 PM INFO org.I0Itec.zkclient.ZkClient
Состояние zookeeper изменено (AuthFailed)
29 июня, 15:02:48:55 INFO org.I0Itec.zkclient.ZkEventThread
Завершить поток событий ZkClient.
29 июня, 15:02: 48.554 FATAL kafka.Kafka $
org.I0Itec.zkclient.exception.ZkTimeoutException: невозможно подключиться к серверу zookeeper в течение таймаута: 6000 в org.I0Itec.zkclient.ZkClient.connect (ZkClient.java:1223) в org.I0Itec.zkclient.ZkClient. (ZkClient. : 155) в org.I0Itec.zkclient.ZkClient. (ZkClient.java:129) в kafka.utils.ZkUtils $ .createZkClientAndConnection (ZkUtils.scala: 80) в kafka.utils.ZkUtils $ .apply (ZkUtils.scala: 62 ) на nl.techop.kafka.dao.zookeeper.KafkaZkClient. (KafkaZkClient.scala: 52) на nl.techop.kafka.KafkaHttpMetricsServer.init (KafkaHttpMetricsServer.scala: 43) на nl.techop. scala: 28) по адресу nl.techop.kafka.KafkaHttpMetricsReporter.init (KafkaHttpMetricsReporter.scala: 41) по адресу kafka.metrics.KafkaMetricsReporter $$ anonfun $ startReporters $ 1.Применить (KafkaMetricsReporter.KafkaMetricsReporter.kafka 60 anonfun $ startReporters $ 1.применить (KafkaMetricsReporter.scala: 58) в scala.collection.IndexedSeqOptimized $ class.f oreach (IndexedSeqOptimized.scala: 33) в scala.collection.mutable.WrappedArray.foreach (WrappedArray.scala: 35) в kafka.metrics.KafkaMetricsReporter $ .startReporters (KafkaMetrics $Reporter.scalaser. (KafkaServerStartable.scala: 27) в kafka.Kafka $ .main (Kafka.scala: 58) в com.cloudera.kafka.wrap.Kafka $ .main (Kafka.scala: 76) в com.cloudera.kafka.wrap. Kafka.main (Kafka.scala)
