You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Manikumar (JIRA)" <ji...@apache.org> on 2018/06/15 18:16:00 UTC

[jira] [Resolved] (KAFKA-3150) kafka.tools.UpdateOffsetsInZK not work (sasl enabled)

     [ https://issues.apache.org/jira/browse/KAFKA-3150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Manikumar resolved KAFKA-3150.
------------------------------
    Resolution: Auto Closed

The Scala consumers and related tools are removed inĀ KAFKA-2983

> 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
>            Priority: Major
>
> ./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
(v7.6.3#76005)