Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-13106

Offsets deletion error

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 2.3.1, 2.7.0
    • 2.7.0
    • admin
    • None
    • Linux

    Description

      When I use:

      kafka-consumer-groups.sh --bootstrap-server broker:9092 --delete-offsets --group myGroup --topic myTopic

       

      I have a error:

       

      SLF4J: Class path contains multiple SLF4J bindings.

      SLF4J: Found binding in [jar:file:/kafka/libs/slf4j-log4j12-1.7.26.jar!/org/slf4j/impl/StaticLoggerBinder.class]

      SLF4J: Found binding in [jar:file:/kafka/libs/slf4j-log4j12-1.7.30.jar!/org/slf4j/impl/StaticLoggerBinder.class]

      SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.

      SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]

      Exception in thread "main" joptsimple.UnrecognizedOptionException: delete-offsets is not a recognized option

              at joptsimple.OptionException.unrecognizedOption(OptionException.java:108)

              at joptsimple.OptionParser.handleLongOptionToken(OptionParser.java:510)

              at joptsimple.OptionParserState$2.handleArgument(OptionParserState.java:56)

              at joptsimple.OptionParser.parse(OptionParser.java:396)

              at kafka.admin.ConsumerGroupCommand$ConsumerGroupCommandOptions.<init>(ConsumerGroupCommand.scala:917)

              at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:46)

              at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala)

       

      When I use kafka protocol base on:
      https://kafka.apache.org/protocol#The_Messages_OffsetDelete

      I have kafka log:

      [2021-07-20 07:23:37,832] ERROR Closing socket for 10.1.1.20:9092-192.168.65.3:56050-0 because of error (kafka.network.Processor)

      org.apache.kafka.common.errors.InvalidRequestException: Unknown API key 47

      [2021-07-20 07:23:37,835] ERROR Exception while processing request from 10.1.1.20:9092-192.168.65.3:56050-0 (kafka.network.Processor)

      org.apache.kafka.common.errors.InvalidRequestException: Unknown API key 47

      Base on:
      https://cwiki.apache.org/confluence/display/KAFKA/KIP-496%3A+Administrative+API+to+delete+consumer+offsets

      Those things should be working.

      Attachments

        Activity

          People

            Unassigned Unassigned
            robert.janda Robert Janda
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: