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)
