Major 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
Those things should be working.