linbao111 created KAFKA-3150: -------------------------------- Summary: kafka.tools.UpdateOffsetsInZK not work (sasl enabled) Key: KAFKA-3150 URL: https://issues.apache.org/jira/browse/KAFKA-3150 Project: Kafka Issue Type: Bug Affects Versions: 0.9.0.1 Environment: redhat as6.5 Reporter: linbao111
./bin/kafka-run-class.sh kafka.tools.UpdateOffsetsInZK earliest config/consumer.properties alalei_2 [2016-01-26 17:20:49,920] WARN Property sasl.kerberos.service.name is not valid (kafka.utils.VerifiableProperties) [2016-01-26 17:20:49,920] WARN Property security.protocol is not valid (kafka.utils.VerifiableProperties) Exception in thread "main" kafka.common.BrokerEndPointNotAvailableException: End point PLAINTEXT not found for broker 1 at kafka.cluster.Broker.getBrokerEndPoint(Broker.scala:136) at kafka.tools.UpdateOffsetsInZK$$anonfun$getAndSetOffsets$2.apply$mcVI$sp(UpdateOffsetsInZK.scala:70) at kafka.tools.UpdateOffsetsInZK$$anonfun$getAndSetOffsets$2.apply(UpdateOffsetsInZK.scala:59) at kafka.tools.UpdateOffsetsInZK$$anonfun$getAndSetOffsets$2.apply(UpdateOffsetsInZK.scala:59) at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59) at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47) at kafka.tools.UpdateOffsetsInZK$.getAndSetOffsets(UpdateOffsetsInZK.scala:59) at kafka.tools.UpdateOffsetsInZK$.main(UpdateOffsetsInZK.scala:43) at kafka.tools.UpdateOffsetsInZK.main(UpdateOffsetsInZK.scala) same error for: ./bin/kafka-consumer-offset-checker.sh --broker-info --group test-consumer-group --topic alalei_2 --zookeeper slave1:2181 [2016-01-26 17:23:45,218] WARN WARNING: ConsumerOffsetChecker is deprecated and will be dropped in releases following 0.9.0. Use ConsumerGroupCommand instead. (kafka.tools.ConsumerOffsetChecker$) Exiting due to: End point PLAINTEXT not found for broker 0. ./bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper slave1:2181 --group test-consumer-group [2016-01-26 17:26:15,075] WARN WARNING: ConsumerOffsetChecker is deprecated and will be dropped in releases following 0.9.0. Use ConsumerGroupCommand instead. (kafka.tools.ConsumerOffsetChecker$) Exiting due to: End point PLAINTEXT not found for broker 0 -- This message was sent by Atlassian JIRA (v6.3.4#6332)