Robert Janda created KAFKA-13106: ------------------------------------ Summary: Offsets deletion error Key: KAFKA-13106 URL: https://issues.apache.org/jira/browse/KAFKA-13106 Project: Kafka Issue Type: Bug Components: admin Affects Versions: 2.7.0, 2.3.1 Environment: Linux Reporter: Robert Janda Fix For: 2.7.0
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. -- This message was sent by Atlassian Jira (v8.3.4#803005)