kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Patrik Kleindl (Jira)" <j...@apache.org>
Subject [jira] [Resolved] (KAFKA-8838) Allow consumer group tool to work with non-existing consumer groups
Date Thu, 12 Sep 2019 09:15:00 GMT

     [ https://issues.apache.org/jira/browse/KAFKA-8838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Patrik Kleindl resolved KAFKA-8838.
-----------------------------------
    Resolution: Not A Problem

> Allow consumer group tool to work with non-existing consumer groups
> -------------------------------------------------------------------
>
>                 Key: KAFKA-8838
>                 URL: https://issues.apache.org/jira/browse/KAFKA-8838
>             Project: Kafka
>          Issue Type: Improvement
>          Components: tools
>            Reporter: Patrik Kleindl
>            Priority: Minor
>
> The streams application reset tool works for non-existing consumer groups and allows
to "pre-set" offsets before a new deployment.
> The consumer group tool does not allow the same which would be a nice enhancement.
> If this should work and the NullPointerException is not expected this can be converted
to a bug.
>  
> {code:java}
> ./kafka-consumer-groups --bootstrap-server broker:9092 --group applicationId --reset-offsets
--by-duration P60D --topic topic1 --executeError: Executing consumer group command failed
due to nulljava.lang.NullPointerException at scala.collection.convert.Wrappers$JListWrapper.iterator(Wrappers.scala:88)
at scala.collection.IterableLike$class.foreach(IterableLike.scala:72) at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
at scala.collection.TraversableLike$class.map(TraversableLike.scala:234) at scala.collection.AbstractTraversable.map(Traversable.scala:104)
at kafka.admin.ConsumerGroupCommand$ConsumerGroupService$$anonfun$parseTopicPartitionsToReset$1.apply(ConsumerGroupCommand.scala:477)
at kafka.admin.ConsumerGroupCommand$ConsumerGroupService$$anonfun$parseTopicPartitionsToReset$1.apply(ConsumerGroupCommand.scala:471)
at scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:241) at
scala.collection.TraversableLike$$anonfun$flatMap$1.apply(TraversableLike.scala:241) at scala.collection.Iterator$class.foreach(Iterator.scala:891)
at scala.collection.AbstractIterator.foreach(Iterator.scala:1334) at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
at scala.collection.AbstractIterable.foreach(Iterable.scala:54) at scala.collection.TraversableLike$class.flatMap(TraversableLike.scala:241)
at scala.collection.AbstractTraversable.flatMap(Traversable.scala:104) at kafka.admin.ConsumerGroupCommand$ConsumerGroupService.parseTopicPartitionsToReset(ConsumerGroupCommand.scala:471)
at kafka.admin.ConsumerGroupCommand$ConsumerGroupService.getPartitionsToReset(ConsumerGroupCommand.scala:486)
at kafka.admin.ConsumerGroupCommand$ConsumerGroupService.resetOffsets(ConsumerGroupCommand.scala:310)
at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:64) at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala){code}



--
This message was sent by Atlassian Jira
(v8.3.2#803003)

Mime
View raw message