kafka 添加kerberos认证
kafka版本：kafka_2.11-0.9.0.1
zookeeper版本：zookeeper-3.5.3
./kafka-console-consumer.sh --zookeeper node1:2181 --topic test --from-beginning --consumer.config ../config/consumer.properties
[2018-02-24 11:54:35,257] WARN [test-consumer-group_node1-1519444006293-12a51dac-leader-finder-thread], Failed to find leader for Set([test,0]) (kafka.consumer.ConsumerFetcherManager$LeaderFinderThread)
kafka.common.BrokerEndPointNotAvailableException: End point PLAINTEXT not found for broker 3
at kafka.cluster.Broker.getBrokerEndPoint(Broker.scala:141)
at kafka.utils.ZkUtils$$ anonfun$getAllBrokerEndPointsForChannel$1.apply(ZkUtils.scala:180) at kafka.utils.ZkUtils $$
anonfun$getAllBrokerEndPointsForChannel$1.apply(ZkUtils.scala:180)
at scala.collection.TraversableLike$$ anonfun$map$1.apply(TraversableLike.scala:245) at scala.collection.TraversableLike $$
anonfun$map$1.apply(TraversableLike.scala:245)
at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48)
at scala.collection.TraversableLike$class.map(TraversableLike.scala:245)
at scala.collection.AbstractTraversable.map(Traversable.scala:104)
at kafka.utils.ZkUtils.getAllBrokerEndPointsForChannel(ZkUtils.scala:180)
at kafka.consumer.ConsumerFetcherManager$LeaderFinderThread.doWork(ConsumerFetcherManager.scala:65)
at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:63)
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
