[jira] [Created] (KAFKA-13733) Reset consumer group offset with not exist topic throw wrong exception

[Yujie Li (Jira)]

Yujie Li created KAFKA-13733:
--------------------------------

             Summary: Reset consumer group offset with not exist topic throw 
wrong exception
                 Key: KAFKA-13733
                 URL: https://issues.apache.org/jira/browse/KAFKA-13733
             Project: Kafka
          Issue Type: Bug
          Components: core
            Reporter: Yujie Li


Hey,

I'm seen a bug with misleading exception when I try to reset consumer group 
offset with not exist topic by:
kafka-consumer-groups --bootstrap-server $brokers --reset-offsets --group 
<consumer-group-name> --topic <topic-not-exist>:0 --to-offset <offset-num>
And got:
Error: Executing consumer group command failed due to 
org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node 
assignment. Call: metadata
java.util.concurrent.ExecutionException: 
org.apache.kafka.common.errors.TimeoutException: Timed out waiting for a node 
assignment. Call: metadata
        at 
java.base/java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:395)
        at 
java.base/java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1999)
        at 
org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:165)
        at 
kafka.admin.ConsumerGroupCommand$ConsumerGroupService.getLogStartOffsets(ConsumerGroupCommand.scala:654)
        at 
kafka.admin.ConsumerGroupCommand$ConsumerGroupService.checkOffsetsRange(ConsumerGroupCommand.scala:888)
        at 
kafka.admin.ConsumerGroupCommand$ConsumerGroupService.prepareOffsetsToReset(ConsumerGroupCommand.scala:796)
        at 
kafka.admin.ConsumerGroupCommand$ConsumerGroupService.$anonfun$resetOffsets$1(ConsumerGroupCommand.scala:437)
        at scala.collection.IterableOnceOps.foldLeft(IterableOnce.scala:646)
        at scala.collection.IterableOnceOps.foldLeft$(IterableOnce.scala:642)
        at scala.collection.AbstractIterable.foldLeft(Iterable.scala:919)
        at 
kafka.admin.ConsumerGroupCommand$ConsumerGroupService.resetOffsets(ConsumerGroupCommand.scala:432)
        at kafka.admin.ConsumerGroupCommand$.run(ConsumerGroupCommand.scala:76)
        at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:59)
        at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala)
Caused by: org.apache.kafka.common.errors.TimeoutException: Timed out waiting 
for a node assignment. Call: metadata
I think it should throw TopicNotExistException/NotAuthorizeException instead. 

 

Let me know what do you think!

 

Thanks,

Yujie



--
This message was sent by Atlassian Jira
(v8.20.1#820001)