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)
