使用して失敗しました:2.0.1 Kerberosが有効になっているが、私はClouderaののmanegerを使用してカフカにSASLを有効にするとSASL認証は、ログインコンテキスト「クライアント」私はCDHにケルベロスで5.5 カフカのバージョンをカフカの確保で働いています
正常に動作します、私はエラーを取得:
6月29日、3:02:42.875 PM/127.0.0.1サーバーbrahim.localhostにINFO org.apache.zookeeper.ClientCnxn
オープニングソケット接続:2181。ログインコンテキストセクション 'クライアント' を使用してSASL-認証を試みます
6月29日、3:02:42.879 PM INFO org.apache.zookeeper.ClientCnxn
ソケット接続brahim.localhostために設立/ 127.0.0.1: 2181年、セッション
6月29日、3開始:02:42.906 PM INFO org.apache.zookeeper.ClientCnxn
サーバーbrahim.localhost/127.0.0.1の完全なセッションの確立:2181、セッションID = 0x1559c20b6110007、交渉しタイムアウトを= 30000
6月29日、3:02:02:42.942 PM ERRORのorg.apache.zookeeper.client 42.910 PM INFO org.I0Itec.zkclient.ZkClient
飼育係の状態は(SyncConnected)
6月29日、3を変更しました。 ZooKeeperSaslClient
ログインコンテキスト 'Client'を使用してSASL認証に失敗しました。
06月29日3:02:02:48.551 PM INFO org.I0Itec.zkclient 42.942 PM INFO org.I0Itec.zkclient.ZkClient
飼育係状態が(AuthFailed)
06月29 3を変更.ZkEventThread
ZkClientイベントスレッドを終了します。
6月29日、3:02:48.554 PM FATAL kafka.Kafka $
org.I0Itec.zkclient.exception.ZkTimeoutException:タイムアウト時間内にサーバーを飼育係に接続することができません:org.I0Itec.zkclientで6000 。 ZkClient.connect(ZkClient.java:1223) at org.I0Itec.zkclient.ZkClient(ZkClient.java:155) at org.I0Itec.zkclient.ZkClient(ZkClient.java:129) at kafka.utils。 nl.techop.kafka.dao.zookeeper.KafkaZkClientで (KafkaZkClient.scala:52):kafka.utils.ZkUtils $ .applyで (62 ZkUtils.scala):ZkUtils $ .createZkClientAndConnection(80 ZkUtils.scala)。 nl.techop.kafkaで。 nl.techop.kafka.KafkaHttpMetricsServerで (KafkaHttpMetricsServer.scala:28):KafkaHttpMetricsServer.init(43 KafkaHttpMetricsServer.scala)。 nl.techop.kafka.KafkaHttpMetricsReporter.init(KafkaHttpMetricsReporter.scala:41)でkafka.metricsで .KafkaMetricsReporter $$ anonfun $ startReporters $ 1.apply(KafkaMetricsReporter.scala:60) kafka.metrics.KafkaMetricsReporter at $$ anonfun $ startReporters $ 1.apply(KafkaMetricsReporter.scala:58) at scala.collection.IndexedSeqOptimized $ class.foreach (IndexedSeqOptimized.scala:33) (scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:35) 、kafka.metrics)。KafkaMetricsReporter $ .startReporters(KafkaMetricsReporter.scala:58) kafka.server.KafkaServerStartable $ .fromProps(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)