ich bei der Sicherung Kafka mit Kerberos in CDH 5.5 Kafka Version arbeite: 2.0.1 Kerberos aktiviert ist und funktioniert gutSASL-Authentifizierung fehlgeschlagen Anmeldekontext 'Client' mit
wenn ich sasl in kafka mit cloudera maneger ermöglichen , erhalte ich die Fehlermeldung:
Jun 29, 3: 02: 42,875 Uhr INFO org.apache.zookeeper.ClientCnxn
Öffnungs Socket-Verbindung zum Server brahim.localhost/127.0.0.1: 2181. versuchen werden, SASL-Authentifizierung mittels Login-Context Abschnitt 'Client'
Jun 29, 3: 02: 42,879 Uhr INFO org.apache.zookeeper.ClientCnxn
Socketverbindung aufgebaut brahim.localhost/127.0.0.1: 2181, Sitzung
Jun 29, 3 Einleitung: 02: 42,906 Uhr INFO org.apache.zookeeper.ClientCnxn
Session Einrichtung komplett auf dem Server brahim.localhost/127.0.0.1: 2181, sessionid = 0x1559c20b6110007 verhandelte Timeout = 30000
Jun 29, 3: 02: 42,910 Uhr INFO org.I0Itec.zkclient.ZkClient
zookeeper Zustand geändert (SyncConnected)
29 Jun 3: 02: 42,942 Uhr ERROR org.apache.zookeeper.client. ZooKeeperSaslClient
Die SASL-Authentifizierung ist mit dem Anmeldekontext 'Client' fehlgeschlagen.
Jun 29, 3: 02: 42,942 Uhr INFO org.I0Itec.zkclient.ZkClient
zookeeper Zustand geändert (AuthFailed)
29 Jun 3: 02: 48,551 Uhr INFO org.I0Itec.zkclient .ZkEventThread
ZkClient-Ereignis-Thread beenden.
Jun 29, 3: 02: 48,554 Uhr FATAL kafka.Kafka
$org.I0Itec.zkclient.exception.ZkTimeoutException: Es konnte keine Verbindung Server innerhalb Timeout Zoowärter: 6000 bei org.I0Itec.zkclient. ZkClient.connect (ZkClient.java:1223) bei org.I0Itec.zkclient.ZkClient. (ZkClient.java:155) bei org.I0Itec.zkclient.ZkClient. (ZkClient.java:129) at kafka.utils. ZkUtils $ .createZkClientAndConnection (ZkUtils.scala: 80) bei kafka.utils.ZkUtils $ .apply (ZkUtils.scala: 62) bei nl.techop.kafka.dao.zookeeper.KafkaZkClient (KafkaZkClient.scala: 52). bei nl.techop.kafka. KafkaHttpMetricsServer.init (KafkaHttpMetricsServer.scala: 43) bei nl.techop.kafka.KafkaHttpMetricsServer (KafkaHttpMetricsServer.scala: 28). bei nl.techop.kafka.KafkaHttpMetricsReporter.init (KafkaHttpMetricsReporter.scala: 41) bei kafka.metrics .KafkaMetricsReporter $$ anonfun $ startReporters $ 1.Anwendung (KafkaMetricsReporter.scala: 60) bei kafka.metrics.KafkaMetricsReporter $$ anonfun $ startReporters $ 1.apply (KafkaMetricsReporter.scala: 58) bei scala.collection.IndexedSeqOptimized $ class.foreach (IndexedSeqOptimized.scala: 33) bei scala.collection.mutable.WrappedArray.foreach (WrappedArray.scala: 35) bei kafka.metrics.KafkaMetricsReporter $ .startReporters (KafkaMetricsReporter.scala: 58) bei kafka.server.KafkaServerStartable $ .fromProps (KafkaServerStartable.scala: 27) bei kafka.Kafka $ .main (Kafka.scala: 58) bei com.cloudera.kafka .wrap.Kafka $ .main (Kafka.scala: 76) bei com.cloudera.kafka.wrap.Kafka.main (Kafka.scala)